import com.sun.corba.se.pept.transport.Connection; //导入依赖的package包/类
public MessageMediator createMessageMediator(Broker broker,
                                             ContactInfo contactInfo,
                                             Connection connection,
                                             String methodName,
                                             boolean isOneWay)
{
    // REVISIT: Would like version, ior, requestid, etc., decisions
    // to be in client subcontract.  Cannot pass these to this
    // factory method because it breaks generic abstraction.
    // Maybe set methods on mediator called from subcontract
    // after creation?
    CorbaMessageMediator messageMediator =
        new CorbaMessageMediatorImpl(
            (ORB) broker,
            contactInfo,
            connection,
            GIOPVersion.chooseRequestVersion( (ORB)broker,
                 effectiveTargetIOR),
            effectiveTargetIOR,
            ((CorbaConnection)connection).getNextRequestId(),
            getAddressingDisposition(),
            methodName,
            isOneWay);

    return messageMediator;
}
 

import com.sun.corba.se.pept.transport.Connection; //导入依赖的package包/类
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;
}
 

import com.sun.corba.se.pept.transport.Connection; //导入依赖的package包/类
private void sendFragment(boolean isLastFragment)
{
    Connection conn = ((OutputObject)outputObject).getMessageMediator().getConnection();

    // REVISIT: need an ORB
    //System.out.println("sendFragment: last?: " + isLastFragment);
    conn.writeLock();

    try {
        // Send the fragment
        conn.sendWithoutLock(((OutputObject)outputObject));

        fragmentCount++;

    } finally {

        conn.writeUnlock();
    }

}
 

import com.sun.corba.se.pept.transport.Connection; //导入依赖的package包/类
public CorbaMessageMediatorImpl(ORB orb,
                                ContactInfo contactInfo,
                                Connection connection,
                                GIOPVersion giopVersion,
                                IOR ior,
                                int requestId,
                                short addrDisposition,
                                String operationName,
                                boolean isOneWay)
{
    this( orb, connection ) ;

    this.contactInfo = (CorbaContactInfo) contactInfo;
    this.addrDisposition = addrDisposition;

    streamFormatVersion =
        getStreamFormatVersionForThisRequest(
            ((CorbaContactInfo)this.contactInfo).getEffectiveTargetIOR(),
            giopVersion);
    streamFormatVersionSet = true;

    requestHeader = (RequestMessage) MessageBase.createRequest(
        this.orb,
        giopVersion,
        ORBUtility.getEncodingVersion(orb, ior),
        requestId,
        !isOneWay,
        ((CorbaContactInfo)this.contactInfo).getEffectiveTargetIOR(),
        this.addrDisposition,
        operationName,
        new ServiceContexts(orb),
        null);
}
 

import com.sun.corba.se.pept.transport.Connection; //导入依赖的package包/类
public Connection createConnection()
{
    Connection connection =
        new SocketFactoryConnectionImpl(
            orb, this,
            orb.getORBData().connectionSocketUseSelectThreadToWait(),
            orb.getORBData().connectionSocketUseWorkerThreadForEvent());
    return connection;
}
 

import com.sun.corba.se.pept.transport.Connection; //导入依赖的package包/类
public MessageMediator finishCreatingMessageMediator(Broker broker,
                           Connection conn, MessageMediator messageMediator)
{
    ORB orb = (ORB) broker;
    CorbaConnection connection = (CorbaConnection) conn;
    CorbaMessageMediator corbaMessageMediator =
                  (CorbaMessageMediator)messageMediator;

    if (orb.transportDebugFlag) {
        dprint(
        ".finishCreatingMessageMediator: waiting for message body on connection: "
            + connection);
    }

    Message msg = corbaMessageMediator.getDispatchHeader();
    msg.setByteBuffer(corbaMessageMediator.getDispatchBuffer());

    // read giop body only
    msg = MessageBase.readGIOPBody(orb, connection, msg);

    ByteBuffer byteBuffer = msg.getByteBuffer();
    msg.setByteBuffer(null);
    corbaMessageMediator.setDispatchHeader(msg);
    corbaMessageMediator.setDispatchBuffer(byteBuffer);

    return corbaMessageMediator;
}
 

import com.sun.corba.se.pept.transport.Connection; //导入依赖的package包/类
public ReaderThreadImpl(ORB orb,
                        Connection connection, Selector selector)
{
    this.orb = orb;
    this.connection = connection;
    this.selector = selector;
    keepRunning = true;
}
 

import com.sun.corba.se.pept.transport.Connection; //导入依赖的package包/类
public Connection createConnection()
{
    Connection connection =
        new SocketOrChannelConnectionImpl(orb, this,
                                          socketType, hostname, port);
    return connection;
}
 

import com.sun.corba.se.pept.transport.Connection; //导入依赖的package包/类
public void put(Acceptor acceptor, Connection connection)
{
    if (orb.transportDebugFlag) {
        dprint(".put: " + acceptor + " " + connection);
    }
    synchronized (backingStore()) {
        connectionCache.add(connection);
        connection.setConnectionCache(this);
        dprintStatistics();
    }
}
 

import com.sun.corba.se.pept.transport.Connection; //导入依赖的package包/类
public void remove(Connection connection)
{
    if (orb.transportDebugFlag) {
        dprint(".remove: " +  connection);
    }
    synchronized (backingStore()) {
        connectionCache.remove(connection);
        dprintStatistics();
    }
}
 

import com.sun.corba.se.pept.transport.Connection; //导入依赖的package包/类
public MessageMediator createMessageMediator(Broker broker,
                                             Connection connection)
{
    // REVISIT - no factoring so cheat to avoid code dup right now.
    // REVISIT **** COUPLING !!!!
    ContactInfo contactInfo = new SocketOrChannelContactInfoImpl();
    return contactInfo.createMessageMediator(broker, connection);
}
 

import com.sun.corba.se.pept.transport.Connection; //导入依赖的package包/类
public MessageMediator finishCreatingMessageMediator(Broker broker,
                                                     Connection connection,
                                                     MessageMediator messageMediator)
{
    // REVISIT - no factoring so cheat to avoid code dup right now.
    // REVISIT **** COUPLING !!!!
    ContactInfo contactInfo = new SocketOrChannelContactInfoImpl();
    return contactInfo.finishCreatingMessageMediator(broker,
                                      connection, messageMediator);
}
 

import com.sun.corba.se.pept.transport.Connection; //导入依赖的package包/类
public Connection get(ContactInfo contactInfo)
{
    if (orb.transportDebugFlag) {
        dprint(".get: " + contactInfo + " " + contactInfo.hashCode());
    }
    synchronized (backingStore()) {
        dprintStatistics();
        return (Connection) connectionCache.get(contactInfo);
    }
}
 

import com.sun.corba.se.pept.transport.Connection; //导入依赖的package包/类
public void put(ContactInfo contactInfo, Connection connection)
{
    if (orb.transportDebugFlag) {
        dprint(".put: " + contactInfo + " " + contactInfo.hashCode() + " "
               + connection);
    }
    synchronized (backingStore()) {
        connectionCache.put(contactInfo, connection);
        connection.setConnectionCache(this);
        dprintStatistics();
    }
}
 

import com.sun.corba.se.pept.transport.Connection; //导入依赖的package包/类
public long numberOfIdleConnections()
{
    long count = 0;
    synchronized (backingStore()) {
        Iterator connections = values().iterator();
        while (connections.hasNext()) {
            if (! ((Connection)connections.next()).isBusy()) {
                count++;
            }
        }
    }
    return count;
}
 

import com.sun.corba.se.pept.transport.Connection; //导入依赖的package包/类
public long numberOfBusyConnections()
{
    long count = 0;
    synchronized (backingStore()) {
        Iterator connections = values().iterator();
        while (connections.hasNext()) {
            if (((Connection)connections.next()).isBusy()) {
                count++;
            }
        }
    }
    return count;
}