com.perforce.p4java.impl.mapbased.rpc.stream
Class RpcSocketPool

java.lang.Object
  com.perforce.p4java.impl.mapbased.rpc.stream.RpcSocketPool

public class RpcSocketPool
extends Object

Author:

Kevin Sawicki ([email protected])

RpcSocketPool

public RpcSocketPool(int poolSize,
                     String host,
                     int port,
                     Properties socketProperties,
                     RpcSocketPool.ShutdownHandler shutdownHandler,
                     boolean secure)

Create a new socket pool indicating whether it is secure (SSL) or not.

Parameters:

poolSize -

host -

port -

socketProperties -

shutdownHandler -

secureServer -

RpcSocketPool

public RpcSocketPool(int poolSize,
                     String host,
                     int port,
                     Properties socketProperties,
                     RpcSocketPool.ShutdownHandler shutdownHandler)

Create a new socket pool with a max pool size, host, port, and socket properties, and an optional shutdown handler

Parameters:

poolSize -

host -

port -

socketProperties -

shutdownHandler -

acquire

public Socket acquire()
               throws IOException

Acquire a socket to the configured server address

Returns:

- socket

Throws:

IOException

release

public void release(Socket socket,
                    RpcSocketPool.ShutdownHandler shutdownHandler)
             throws IOException

Release a socket back to the pool as no longer using

Parameters:

socket -

shutdownHandler -

Throws:

IOException

disconnect

public void disconnect()

Disconnect all sockets from the specified host and port

timeout

public void timeout(int idleDuration)

Timeout any sockets idle for greater than or equal to the milliseconds value specified

Parameters:

idleDuration -