| Methods Summary |
|---|
| public void | addToIORTemplate(com.sun.corba.se.spi.ior.IORTemplate iorTemplate, com.sun.corba.se.impl.oa.poa.Policies policies, java.lang.String codebase, java.lang.String objectAdapterManagerId, com.sun.corba.se.spi.ior.ObjectAdapterId objectAdapterId)
Iterator iterator =
getAcceptors(objectAdapterManagerId, objectAdapterId).iterator();
while (iterator.hasNext()) {
CorbaAcceptor acceptor = (CorbaAcceptor) iterator.next();
acceptor.addToIORTemplate(iorTemplate, policies, codebase);
}
|
| public void | close()
try {
if (orb.transportDebugFlag) {
dprint(".close->");
}
getSelector(0).close();
} finally {
if (orb.transportDebugFlag) {
dprint(".close<-");
}
}
|
| protected void | dprint(java.lang.String msg)
ORBUtility.dprint("CorbaTransportManagerImpl", msg);
|
| public java.util.Collection | getAcceptors(java.lang.String objectAdapterManagerId, com.sun.corba.se.spi.ior.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;
|
| public java.util.Collection | getAcceptors()
return getAcceptors(null, null);
|
| public com.sun.corba.se.pept.transport.ByteBufferPool | getByteBufferPool(int id)
throw new RuntimeException();
|
| public com.sun.corba.se.pept.transport.InboundConnectionCache | getInboundConnectionCache(com.sun.corba.se.pept.transport.Acceptor acceptor)
synchronized (acceptor) {
if (acceptor.getConnectionCache() == null) {
InboundConnectionCache connectionCache = null;
synchronized (inboundConnectionCaches) {
connectionCache = (InboundConnectionCache)
inboundConnectionCaches.get(
acceptor.getConnectionCacheType());
if (connectionCache == null) {
// REVISIT: Would like to be able to configure
// the connection cache type used.
connectionCache =
new CorbaInboundConnectionCacheImpl(orb,
acceptor);
inboundConnectionCaches.put(
acceptor.getConnectionCacheType(),
connectionCache);
}
}
acceptor.setConnectionCache(connectionCache);
}
return acceptor.getConnectionCache();
}
|
| public java.util.Collection | getInboundConnectionCaches()
return inboundConnectionCaches.values();
|
| public com.sun.corba.se.pept.transport.OutboundConnectionCache | getOutboundConnectionCache(com.sun.corba.se.pept.transport.ContactInfo contactInfo)
synchronized (contactInfo) {
if (contactInfo.getConnectionCache() == null) {
OutboundConnectionCache connectionCache = null;
synchronized (outboundConnectionCaches) {
connectionCache = (OutboundConnectionCache)
outboundConnectionCaches.get(
contactInfo.getConnectionCacheType());
if (connectionCache == null) {
// REVISIT: Would like to be able to configure
// the connection cache type used.
connectionCache =
new CorbaOutboundConnectionCacheImpl(orb,
contactInfo);
outboundConnectionCaches.put(
contactInfo.getConnectionCacheType(),
connectionCache);
}
}
contactInfo.setConnectionCache(connectionCache);
}
return contactInfo.getConnectionCache();
}
|
| public java.util.Collection | getOutboundConnectionCaches()
return outboundConnectionCaches.values();
|
| public com.sun.corba.se.pept.transport.Selector | getSelector(int id)
return selector;
|
| public synchronized void | registerAcceptor(com.sun.corba.se.pept.transport.Acceptor acceptor)
if (orb.transportDebugFlag) {
dprint(".registerAcceptor->: " + acceptor);
}
acceptors.add(acceptor);
if (orb.transportDebugFlag) {
dprint(".registerAcceptor<-: " + acceptor);
}
|
| public synchronized void | unregisterAcceptor(com.sun.corba.se.pept.transport.Acceptor acceptor)
acceptors.remove(acceptor);
|
