com.sun.corba.se.impl.transport

Class CorbaConnectionCacheBase

java.lang.Object

com.sun.corba.se.impl.transport.CorbaConnectionCacheBase

All Implemented Interfaces:

ConnectionCache, CorbaConnectionCache

Direct Known Subclasses:

CorbaInboundConnectionCacheImpl, CorbaOutboundConnectionCacheImpl

public abstract class CorbaConnectionCacheBase
extends Object
implements ConnectionCache, CorbaConnectionCache

Author:

Harold Carr

Field Summary

Fields

Modifier and Type	Field and Description
protected String	cacheType
protected String	monitoringName
protected ORB	orb
protected long	timestamp
protected ORBUtilSystemException	wrapper

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	CorbaConnectionCacheBase(ORB orb, String cacheType, String monitoringName)

Method Summary

Modifier and Type	Method and Description
protected abstract Object	backingStore()
void	close() Close all connections in the connection cache.
protected void	dprint(String msg)
protected void	dprintCreation()
protected void	dprintStatistics()
String	getCacheType()
String	getMonitoringName()
long	numberOfBusyConnections()
long	numberOfConnections()
long	numberOfIdleConnections()
boolean	reclaim() Discarding least recently used Connections that are not busy This method must be synchronized since one WorkerThread could be reclaming connections inside the synchronized backingStore block and a second WorkerThread (or a SelectorThread) could have already executed the if (numberOfConnections <= ....
protected abstract void	registerWithMonitoring()
void	stampTime(Connection c)
abstract Collection	values()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

orb

protected ORB orb

timestamp

protected long timestamp

cacheType

protected String cacheType

monitoringName

protected String monitoringName

wrapper

protected ORBUtilSystemException wrapper

Constructor Detail

CorbaConnectionCacheBase

protected CorbaConnectionCacheBase(ORB orb,
                                   String cacheType,
                                   String monitoringName)

Method Detail

getCacheType

public String getCacheType()

Specified by:

getCacheType in interface ConnectionCache

stampTime

public void stampTime(Connection c)

Specified by:

stampTime in interface ConnectionCache

numberOfConnections

public long numberOfConnections()

Specified by:

numberOfConnections in interface ConnectionCache

close

public void close()

Description copied from interface: ConnectionCache

Close all connections in the connection cache. This is used as a final cleanup, and will result in abrupt termination of any pending communications.

Specified by:

close in interface ConnectionCache

numberOfIdleConnections

public long numberOfIdleConnections()

Specified by:

numberOfIdleConnections in interface ConnectionCache

numberOfBusyConnections

public long numberOfBusyConnections()

Specified by:

numberOfBusyConnections in interface ConnectionCache

reclaim

public boolean reclaim()

Discarding least recently used Connections that are not busy This method must be synchronized since one WorkerThread could be reclaming connections inside the synchronized backingStore block and a second WorkerThread (or a SelectorThread) could have already executed the if (numberOfConnections <= .... ). As a result the second thread would also attempt to reclaim connections. If connection reclamation becomes a performance issue, the connection reclamation could make its own task and consequently executed in a separate thread. Currently, the accept & reclaim are done in the same thread, WorkerThread by default. It could be changed such that the SelectorThread would do it for SocketChannels and WorkerThreads for Sockets by updating the ParserTable.

Specified by:

reclaim in interface ConnectionCache

getMonitoringName

public String getMonitoringName()

Specified by:

getMonitoringName in interface CorbaConnectionCache

values

public abstract Collection values()

backingStore

protected abstract Object backingStore()

registerWithMonitoring

protected abstract void registerWithMonitoring()

dprintCreation

protected void dprintCreation()

dprintStatistics

protected void dprintStatistics()

dprint

protected void dprint(String msg)