Package com.orientechnologies.orient.client.remote

Class ORemoteConnectionManager

java.lang.Object

com.orientechnologies.orient.client.remote.ORemoteConnectionManager

public class ORemoteConnectionManager
extends Object

Manages network connections against OrientDB servers. All the connection pools are managed in a Map<url,pool>, but in the future we could have a unique pool per sever and manage database connections over the protocol.

Author:

Luca Garulli (l.garulli--(at)--orientdb.com)

Field Summary

Fields

Modifier and Type	Field	Description
protected final ConcurrentMap<String,ORemoteConnectionPool>	connections
protected final long	idleTimeout
static final String	PARAM_MAX_POOL
protected final long	timeout

Constructor Summary

Constructors

Constructor	Description
ORemoteConnectionManager(OContextConfiguration conf, Timer timer)

Method Summary

Modifier and Type	Method	Description
OChannelBinaryAsynchClient	acquire(String url, OContextConfiguration clientConfiguration)
void	checkIdle()
void	close()
protected void	closePool(ORemoteConnectionPool pool)
void	closePool(String url)
int	getAvailableConnections(String url)
int	getCreatedInstancesInPool(String url)
int	getMaxResources(String url)
ORemoteConnectionPool	getPool(String url)
int	getReusableConnections(String url)
Set<String>	getURLs()
void	release(OChannelBinaryAsynchClient conn)
void	remove(OChannelBinaryAsynchClient conn)
void	removeIfPresent(OChannelBinaryAsynchClient conn)

Methods inherited from class java.lang.Object

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

Field Details

PARAM_MAX_POOL

public static final String PARAM_MAX_POOL

See Also:

• Constant Field Values

connections

protected final ConcurrentMap<String,ORemoteConnectionPool> connections

timeout

protected final long timeout

idleTimeout

protected final long idleTimeout

Constructor Details

ORemoteConnectionManager

public ORemoteConnectionManager(OContextConfiguration conf,
 Timer timer)

Method Details

close

public void close()

acquire

public OChannelBinaryAsynchClient acquire(String url,
 OContextConfiguration clientConfiguration)

release

public void release(OChannelBinaryAsynchClient conn)

remove

public void remove(OChannelBinaryAsynchClient conn)

removeIfPresent

public void removeIfPresent(OChannelBinaryAsynchClient conn)

getURLs

public Set<String> getURLs()

getMaxResources

public int getMaxResources(String url)

getAvailableConnections

public int getAvailableConnections(String url)

getReusableConnections

public int getReusableConnections(String url)

getCreatedInstancesInPool

public int getCreatedInstancesInPool(String url)

closePool

public void closePool(String url)

closePool

protected void closePool(ORemoteConnectionPool pool)

getPool

public ORemoteConnectionPool getPool(String url)

checkIdle

public void checkIdle()