src/java.corba/share/classes/com/sun/corba/se/impl/transport/CorbaInboundConnectionCacheImpl.java
Print this page
*** 52,78 ****
--- 52,98 ----
implements
InboundConnectionCache
{
protected Collection connectionCache;
+ private Acceptor acceptor;
+
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 );
}
+ }
////////////////////////////////////////////////////
//
// pept.transport.InboundConnectionCache
//
+ public void close () {
+
+ super.close();
+ if (orb.transportDebugFlag) {
+ dprint(".close: " + acceptor );
+ }
+ this.acceptor.close();
+
+ }
+
public Connection get(Acceptor acceptor)
{
throw wrapper.methodShouldNotBeCalled();
}
+ public Acceptor getAcceptor () {
+ return acceptor;
+ }
+
public void put(Acceptor acceptor, Connection connection)
{
if (orb.transportDebugFlag) {
dprint(".put: " + acceptor + " " + connection);
}