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, 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 and Description
protected ConcurrentMap<String,ORemoteConnectionPool>	connections
protected long	idleTimeout
static String	PARAM_MAX_POOL
protected long	timeout

Constructor Summary

Constructors

Constructor and Description
ORemoteConnectionManager(OContextConfiguration clientConfiguration, Timer timer)

Method Summary

Modifier and Type	Method and Description
OChannelBinaryAsynchClient	acquire(String iServerURL, 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)

Methods inherited from class java.lang.Object

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

Field Detail

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 Detail

ORemoteConnectionManager

public ORemoteConnectionManager(OContextConfiguration clientConfiguration,
                                Timer timer)

Method Detail

close

public void close()

acquire

public OChannelBinaryAsynchClient acquire(String iServerURL,
                                          OContextConfiguration clientConfiguration)

release

public void release(OChannelBinaryAsynchClient conn)

remove

public void remove(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()