public class RepositoryConnectorPool extends Object implements IRepositoryConnectorPool
Modifier and Type | Class and Description |
---|---|
protected static class |
RepositoryConnectorPool.LocalPool
Actual static mapping connector pool
|
Modifier and Type | Field and Description |
---|---|
static String |
_rcsid |
protected static RepositoryConnectorPool.LocalPool |
localPool
Local connector pool
|
protected IThreadContext |
threadContext
Thread context
|
Constructor and Description |
---|
RepositoryConnectorPool(IThreadContext threadContext)
Constructor
|
Modifier and Type | Method and Description |
---|---|
void |
closeAllConnectors()
Clean up all open repository connector handles.
|
void |
flushUnusedConnectors()
Flush only those connector handles that are currently unused.
|
IRepositoryConnector |
grab(IRepositoryConnection repositoryConnection)
Get a repository connector.
|
IRepositoryConnector[] |
grabMultiple(String[] orderingKeys,
IRepositoryConnection[] repositoryConnections)
Get multiple repository connectors, all at once.
|
void |
pollAllConnectors()
Idle notification for inactive repository connector handles.
|
void |
release(IRepositoryConnection connection,
IRepositoryConnector connector)
Release a repository connector.
|
void |
releaseMultiple(IRepositoryConnection[] connections,
IRepositoryConnector[] connectors)
Release multiple repository connectors.
|
public static final String _rcsid
protected static final RepositoryConnectorPool.LocalPool localPool
protected final IThreadContext threadContext
public RepositoryConnectorPool(IThreadContext threadContext) throws ManifoldCFException
ManifoldCFException
public IRepositoryConnector[] grabMultiple(String[] orderingKeys, IRepositoryConnection[] repositoryConnections) throws ManifoldCFException
grabMultiple
in interface IRepositoryConnectorPool
orderingKeys
- are the keys which determine in what order the connectors are obtained.repositoryConnections
- are the connections to use the build the connector instances.ManifoldCFException
public IRepositoryConnector grab(IRepositoryConnection repositoryConnection) throws ManifoldCFException
grab
in interface IRepositoryConnectorPool
authorityConnection
- is the repository connection to base the connector instance on.ManifoldCFException
public void releaseMultiple(IRepositoryConnection[] connections, IRepositoryConnector[] connectors) throws ManifoldCFException
releaseMultiple
in interface IRepositoryConnectorPool
connections
- are the connections describing the instances to release.connectors
- are the connector instances to release.ManifoldCFException
public void release(IRepositoryConnection connection, IRepositoryConnector connector) throws ManifoldCFException
release
in interface IRepositoryConnectorPool
connection
- is the connection describing the instance to release.connector
- is the connector to release.ManifoldCFException
public void pollAllConnectors() throws ManifoldCFException
pollAllConnectors
in interface IRepositoryConnectorPool
ManifoldCFException
public void flushUnusedConnectors() throws ManifoldCFException
flushUnusedConnectors
in interface IRepositoryConnectorPool
ManifoldCFException
public void closeAllConnectors() throws ManifoldCFException
closeAllConnectors
in interface IRepositoryConnectorPool
ManifoldCFException