import com.sun.corba.se.pept.transport.Acceptor; //导入依赖的package包/类
public Collection getAcceptors(String objectAdapterManagerId,
                               ObjectAdapterId objectAdapterId)
{
    // REVISIT - need to filter based on arguments.

    // REVISIT - initialization will be moved to OA.
    // Lazy initialization of acceptors.
    Iterator iterator = acceptors.iterator();
    while (iterator.hasNext()) {
        Acceptor acceptor = (Acceptor) iterator.next();
        if (acceptor.initialize()) {
            if (acceptor.shouldRegisterAcceptEvent()) {
                orb.getTransportManager().getSelector(0)
                    .registerForEvent(acceptor.getEventHandler());
            }
        }
    }
    return acceptors;
}
 

import com.sun.corba.se.pept.transport.Acceptor; //导入依赖的package包/类
public synchronized void registerAcceptor(Acceptor acceptor)
{
    if (orb.transportDebugFlag) {
        dprint(".registerAcceptor->: " + acceptor);
    }
    acceptors.add(acceptor);
    if (orb.transportDebugFlag) {
        dprint(".registerAcceptor<-: " + acceptor);
    }
}
 

import com.sun.corba.se.pept.transport.Acceptor; //导入依赖的package包/类
public void setAcceptedSocketOptions(Acceptor acceptor,
                                     ServerSocket serverSocket,
                                     Socket socket)
    throws SocketException
{
    // Disable Nagle's algorithm (i.e., always send immediately).
    socket.setTcpNoDelay(true);
    if (keepAlive)
        socket.setKeepAlive(true);
}
 

import com.sun.corba.se.pept.transport.Acceptor; //导入依赖的package包/类
public SocketOrChannelConnectionImpl(ORB orb,
                                     Acceptor acceptor,
                                     Socket socket,
                                     boolean useSelectThreadToWait,
                                     boolean useWorkerThread)
{
    this(orb, useSelectThreadToWait, useWorkerThread);

    this.socket = socket;
    socketChannel = socket.getChannel();
    if (socketChannel != null) {
        // REVISIT
        try {
            boolean isBlocking = !useSelectThreadToWait;
            socketChannel.configureBlocking(isBlocking);
        } catch (IOException e) {
            RuntimeException rte = new RuntimeException();
            rte.initCause(e);
            throw rte;
        }
    }
    this.acceptor = acceptor;

    serverRequestMap = Collections.synchronizedMap(new HashMap());
    isServer = true;

    state = ESTABLISHED;
}
 

import com.sun.corba.se.pept.transport.Acceptor; //导入依赖的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.Acceptor; //导入依赖的package包/类
public ListenerThreadImpl(ORB orb, Acceptor acceptor, Selector selector)
{
    this.orb = orb;
    this.acceptor = acceptor;
    this.selector = selector;
    keepRunning = true;
}
 

import com.sun.corba.se.pept.transport.Acceptor; //导入依赖的package包/类
public CorbaInboundConnectionCacheImpl(ORB orb, Acceptor acceptor)
{
    super(orb, acceptor.getConnectionCacheType(),
          ((CorbaAcceptor)acceptor).getMonitoringName());
    this.connectionCache = new ArrayList();
    this.acceptor = acceptor;
    if (orb.transportDebugFlag) {
        dprint(": " + acceptor );
    }
}