de.ipcon.db.protocol.socket

Class SocketPool

java.lang.Object

de.ipcon.db.protocol.socket.SocketPool

All Implemented Interfaces:

TransportProviderI, java.lang.Runnable

public class SocketPool
extends java.lang.Object
implements java.lang.Runnable, TransportProviderI

Socket pool for performance reasons.

Field Summary

Fields

Modifier and Type	Field and Description
static java.util.concurrent.ExecutorService	EXECUTOR
static org.apache.log4j.Logger	log
static int	MAINTAIN_POOL_INTERVAL
static int	MAX_WAIT_ON_PENSIONEERS
static org.apache.log4j.Logger	rtlog

Constructor Summary

Constructors

Constructor and Description
SocketPool(ServerConnectionI _serverConnection)

Method Summary

Modifier and Type	Method and Description
void	bumpLastActivity() Resets the last-activity timestamp to the current system time.
de.ipcon.db.protocol.socket.SocketPool.Data	getData()
int	getRoundtrips() Returns the total client-server roundtrips since initialization.
java.util.concurrent.atomic.AtomicInteger	getRoundtripsInternal()
ServerConnectionI	getServerConnection() A class for maintaining and interacting with all necessary data structures for handling PooledSockets in a SocketPool.
java.lang.Long	getSessionId(boolean blockUntilAvailable) Returns the Id of the current server-connection.
TransportI	getTransport(java.lang.String reason, boolean needAuth) Returns a usable TransportI for client-server communication.
boolean	isAboutToStop() Returns true, if this TransportProviderI will stop soon, false otherwise.
boolean	isActive(int waitSecs) Blocks for up to waitSecs seconds to determine whether transport activity occurred.
boolean	isDead()
boolean	isNew() Returns true, if this SocketPool is still new.
boolean	isStopped() Returns true, if this TransportProviderI is stopped, false otherwise.
boolean	performMaintenance() Forces a performance run on the managed TransportI-s.
void	releaseTransport(TransportI t, java.lang.Exception e) Releases the passed TransportI again.
void	run() Run method for performing regular maintenance on this SocketPool.
void	setRoundtripsInternal(java.util.concurrent.atomic.AtomicInteger $21)
void	setServerConnection(ServerConnectionI $20)
void	startWorker() Starts the worker thread of this TransportProviderI, which performs maintenance on the managed TransportI-s.
void	stop() Stops this TransportProviderI and terminates all TransportI-s.
void	stop(boolean noJoin)
java.lang.String	toString()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

log

public static final org.apache.log4j.Logger log

rtlog

public static final org.apache.log4j.Logger rtlog

EXECUTOR

public static final java.util.concurrent.ExecutorService EXECUTOR

MAINTAIN_POOL_INTERVAL

public static int MAINTAIN_POOL_INTERVAL

MAX_WAIT_ON_PENSIONEERS

public static int MAX_WAIT_ON_PENSIONEERS

Constructor Detail

SocketPool

public SocketPool(ServerConnectionI _serverConnection)

Method Detail

getRoundtrips

public int getRoundtrips()

Description copied from interface: TransportProviderI

Returns the total client-server roundtrips since initialization.

Specified by:

getRoundtrips in interface TransportProviderI

Returns:

non-negative count of roundtrips

getSessionId

public java.lang.Long getSessionId(boolean blockUntilAvailable)

Description copied from interface: TransportProviderI

Returns the Id of the current server-connection. If blockUntilAvailable is true, will wait until our connection is authenticated at the server.

Specified by:

getSessionId in interface TransportProviderI

getTransport

public TransportI getTransport(java.lang.String reason,
                               boolean needAuth)
                        throws ServerConnectionException

Description copied from interface: TransportProviderI

Returns a usable TransportI for client-server communication. If blockUntilAvailable is true, will wait until our connection is authenticated at the server.

Specified by:

getTransport in interface TransportProviderI

Throws:

ServerConnectionException

releaseTransport

public void releaseTransport(TransportI t,
                             java.lang.Exception e)
                      throws ServerConnectionException,
                             java.lang.IllegalStateException

Description copied from interface: TransportProviderI

Releases the passed TransportI again. The passed Exception is the reason for the release and may be null.

Specified by:

releaseTransport in interface TransportProviderI

Throws:

ServerConnectionException

java.lang.IllegalStateException

startWorker

public void startWorker()

Description copied from interface: TransportProviderI

Starts the worker thread of this TransportProviderI, which performs maintenance on the managed TransportI-s.

Specified by:

startWorker in interface TransportProviderI

performMaintenance

public boolean performMaintenance()

Description copied from interface: TransportProviderI

Forces a performance run on the managed TransportI-s.

Specified by:

performMaintenance in interface TransportProviderI

stop

public void stop()

Description copied from interface: TransportProviderI

Stops this TransportProviderI and terminates all TransportI-s.

Specified by:

stop in interface TransportProviderI

stop

public void stop(boolean noJoin)

isAboutToStop

public boolean isAboutToStop()

Description copied from interface: TransportProviderI

Returns true, if this TransportProviderI will stop soon, false otherwise.

Specified by:

isAboutToStop in interface TransportProviderI

isStopped

public boolean isStopped()

Description copied from interface: TransportProviderI

Returns true, if this TransportProviderI is stopped, false otherwise.

Specified by:

isStopped in interface TransportProviderI

isDead

public boolean isDead()

isNew

public boolean isNew()

Returns true, if this SocketPool is still new.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

bumpLastActivity

public void bumpLastActivity()

Description copied from interface: TransportProviderI

Resets the last-activity timestamp to the current system time.

Specified by:

bumpLastActivity in interface TransportProviderI

isActive

public boolean isActive(int waitSecs)

Description copied from interface: TransportProviderI

Blocks for up to waitSecs seconds to determine whether transport activity occurred.

Specified by:

isActive in interface TransportProviderI

Parameters:

waitSecs - maximum duration to block, in seconds

Returns:

true if activity occurred during the window; false otherwise

run

public void run()

Run method for performing regular maintenance on this SocketPool.

Specified by:

run in interface java.lang.Runnable

getData

public de.ipcon.db.protocol.socket.SocketPool.Data getData()

getServerConnection

public ServerConnectionI getServerConnection()

A class for maintaining and interacting with all necessary data structures for handling PooledSockets in a SocketPool.

setServerConnection

public void setServerConnection(ServerConnectionI $20)

getRoundtripsInternal

public java.util.concurrent.atomic.AtomicInteger getRoundtripsInternal()

setRoundtripsInternal

public void setRoundtripsInternal(java.util.concurrent.atomic.AtomicInteger $21)