/*

 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.

 *

 * This code is free software; you can redistribute it and/or modify it

 * under the terms of the GNU General Public License version 2 only, as

 * particular file as subject to the "Classpath" exception as provided

 *

 * This code is distributed in the hope that it will be useful, but WITHOUT

 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or

 * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License

 * version 2 for more details (a copy is included in the LICENSE file that

 * accompanied this code).

 *

 * You should have received a copy of the GNU General Public License version

 * 2 along with this work; if not, write to the Free Software Foundation,

 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.

 *

 */

package com.sun.corba.se.impl.transport;

import com.sun.corba.se.pept.broker.Broker;

import com.sun.corba.se.pept.encoding.OutputObject;

import com.sun.corba.se.pept.protocol.ClientRequestDispatcher;

import com.sun.corba.se.pept.protocol.MessageMediator;

import com.sun.corba.se.pept.transport.Connection;

import com.sun.corba.se.pept.transport.ContactInfo;

import com.sun.corba.se.spi.orb.ORB;

import com.sun.corba.se.spi.ior.IOR;

import com.sun.corba.se.spi.ior.iiop.GIOPVersion;

import com.sun.corba.se.spi.logging.CORBALogDomains;

import com.sun.corba.se.spi.protocol.CorbaMessageMediator;

import com.sun.corba.se.spi.transport.CorbaContactInfoList;

import com.sun.corba.se.impl.encoding.BufferManagerFactory;

import com.sun.corba.se.impl.encoding.CDROutputObject;

import com.sun.corba.se.impl.encoding.CDROutputStream;

import com.sun.corba.se.impl.logging.ORBUtilSystemException;

import com.sun.corba.se.impl.protocol.CorbaMessageMediatorImpl;

import com.sun.corba.se.impl.protocol.SharedCDRClientRequestDispatcherImpl;

public class SharedCDRContactInfoImpl

    extends

        CorbaContactInfoBase

{

    // This is only necessary for the pi.clientrequestinfo test.

    // It tests that request ids are different.

    // Rather than rewrite the test, just fake it.

    private static int requestId = 0;

    protected ORBUtilSystemException wrapper;

    public SharedCDRContactInfoImpl(

        ORB orb,

        CorbaContactInfoList contactInfoList,

        IOR effectiveTargetIOR,

        short addressingDisposition)

    {

        this.orb = orb;

        this.contactInfoList = contactInfoList;

        this.effectiveTargetIOR = effectiveTargetIOR;

        this.addressingDisposition = addressingDisposition;

    }

    ////////////////////////////////////////////////////

    //

    // pept.transport.ContactInfo

    //

    public ClientRequestDispatcher getClientRequestDispatcher()

    {

        // REVISIT - use registry

        return new SharedCDRClientRequestDispatcherImpl();

    }

    public boolean isConnectionBased()

    {

        return false;

    }

    public boolean shouldCacheConnection()

    {

        return false;

    }

    public String getConnectionCacheType()

    {

        throw getWrapper().methodShouldNotBeCalled();

    }

    public Connection createConnection()

    {

        throw getWrapper().methodShouldNotBeCalled();

    }

    // Called when client making an invocation.

    public MessageMediator createMessageMediator(Broker broker,

                                                 ContactInfo contactInfo,

                                                 Connection connection,

                                                 String methodName,

                                                 boolean isOneWay)

    {

        if (connection != null) {

            /// XXX LOGGING

            throw new RuntimeException("connection is not null");

        }

        CorbaMessageMediator messageMediator =

            new CorbaMessageMediatorImpl(

                (ORB) broker,

                contactInfo,

                null, // Connection;

                GIOPVersion.chooseRequestVersion( (ORB)broker,

                     effectiveTargetIOR),

                effectiveTargetIOR,

                requestId++, // Fake RequestId

                getAddressingDisposition(),

                methodName,

                isOneWay);

        return messageMediator;

    }

    public OutputObject createOutputObject(MessageMediator messageMediator)

    {

        CorbaMessageMediator corbaMessageMediator = (CorbaMessageMediator)

            messageMediator;

        // NOTE: GROW.

        OutputObject outputObject =

            new CDROutputObject(orb, messageMediator,

                                corbaMessageMediator.getRequestHeader(),

                                corbaMessageMediator.getStreamFormatVersion(),

                                BufferManagerFactory.GROW);

        messageMediator.setOutputObject(outputObject);

        return outputObject;

    }

    ////////////////////////////////////////////////////

    //

    // spi.transport.CorbaContactInfo

    //

    public String getMonitoringName()

    {

        throw getWrapper().methodShouldNotBeCalled();

    }

    ////////////////////////////////////////////////////

    //

    // java.lang.Object

    //

    ////////////////////////////////////////////////////

    //

    // java.lang.Object

    //

    public String toString()

    {

        return

            "SharedCDRContactInfoImpl["

            + "]";

    }

    //////////////////////////////////////////////////

    //

    // Implementation

    //

    protected ORBUtilSystemException getWrapper()

    {

        if (wrapper == null) {

            wrapper = ORBUtilSystemException.get( orb,

                          CORBALogDomains.RPC_TRANSPORT ) ;

        }

        return wrapper;

    }

}

// End of file.