org.alfresco.jlan.oncrpc

Class MultiThreadedTcpRpcSessionHandler

java.lang.Object

org.alfresco.jlan.server.SessionHandlerBase

org.alfresco.jlan.server.SocketSessionHandler

org.alfresco.jlan.oncrpc.TcpRpcSessionHandler

org.alfresco.jlan.oncrpc.MultiThreadedTcpRpcSessionHandler

All Implemented Interfaces:

Runnable, SessionHandlerInterface

public class MultiThreadedTcpRpcSessionHandler
extends TcpRpcSessionHandler

Multi-threaded TCP RPC Session Handler Class

Extend the basic TCP RPC handler class to process RPC requests using a thread pool.

Author:

gkspencer

Field Summary

Fields

Modifier and Type	Field and Description
static int	DefaultPacketPoolSize
static int	DefaultSmallPacketSize

Fields inherited from class org.alfresco.jlan.server.SessionHandlerBase

ListenBacklog

Constructor Summary

Constructors

Constructor and Description
MultiThreadedTcpRpcSessionHandler(String name, String protocol, RpcProcessor rpcServer, NetworkServer server, InetAddress addr, int port, int maxSize) Class constructor

Method Summary

Methods

Modifier and Type	Method and Description
protected RpcPacket	allocateRpcPacket(int size) Allocate an RPC packet from the packet pool
protected TcpRpcPacketHandler	createPacketHandler(int sessId, Socket sock) Create a multi-threaded packet handler for the new session
void	initializeSessionHandler(NetworkServer server) Initialize the session socket handler
protected void	queueRpcRequest(RpcPacket rpc) Queue an RPC request to the thread pool for processing
void	setPacketPool(int poolSize) Set the packet pool size
void	setPacketPool(int smallSize, int smallPool, int largeSize, int largePool) Set the packet pool size
void	setPacketPool(RpcPacketPool pktPool) Set the packet pool
void	setThreadPool(int numThreads) Set the thread pool size
void	setThreadPool(RpcRequestThreadPool threadPool) Set the thread pool

Methods inherited from class org.alfresco.jlan.oncrpc.TcpRpcSessionHandler

acceptConnection, closeSession, closeSessionHandler, getMaximumRpcSize, getRpcProcessor

Methods inherited from class org.alfresco.jlan.server.SocketSessionHandler

getSocket, getSocketTimeout, run, setSocketTimeout

Methods inherited from class org.alfresco.jlan.server.SessionHandlerBase

clearShutdown, getBindAddress, getHandlerName, getListenBacklog, getNextSessionId, getPort, getProtocolName, getServer, hasBindAddress, hasDebug, hasShutdown, setDebug, setPort, setShutdown, toString

Methods inherited from class java.lang.Object

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

Field Detail

DefaultPacketPoolSize

public static final int DefaultPacketPoolSize

See Also:

Constant Field Values

DefaultSmallPacketSize

public static final int DefaultSmallPacketSize

See Also:

Constant Field Values

Constructor Detail

MultiThreadedTcpRpcSessionHandler

public MultiThreadedTcpRpcSessionHandler(String name,
                                 String protocol,
                                 RpcProcessor rpcServer,
                                 NetworkServer server,
                                 InetAddress addr,
                                 int port,
                                 int maxSize)

Class constructor

Parameters:

name - String

protocol - String

rpcServer - RpcProcessor

server - NetworkServer

addr - InetAddress

port - int

maxSize - int

Method Detail

initializeSessionHandler

public void initializeSessionHandler(NetworkServer server)
                              throws IOException

Initialize the session socket handler

Specified by:

initializeSessionHandler in interface SessionHandlerInterface

Overrides:

initializeSessionHandler in class SocketSessionHandler

Parameters:

server - NetworkServer

Throws:

IOException

allocateRpcPacket

protected final RpcPacket allocateRpcPacket(int size)

Allocate an RPC packet from the packet pool

Parameters:

size - int

Returns:

RpcPacket

queueRpcRequest

protected final void queueRpcRequest(RpcPacket rpc)

Queue an RPC request to the thread pool for processing

Parameters:

rpc - RpcPacket

createPacketHandler

protected TcpRpcPacketHandler createPacketHandler(int sessId,
                                      Socket sock)
                                           throws IOException

Create a multi-threaded packet handler for the new session

Overrides:

createPacketHandler in class TcpRpcSessionHandler

Parameters:

sessId - int

sock - Socket

Returns:

TcpRpcPacketHandler

Throws:

IOException

setPacketPool

public final void setPacketPool(int smallSize,
                 int smallPool,
                 int largeSize,
                 int largePool)

Set the packet pool size

Parameters:

smallSize - int

smallPool - int

largeSize - int

largePool - int

setPacketPool

public final void setPacketPool(int poolSize)

Set the packet pool size

Parameters:

poolSize - int

setPacketPool

public final void setPacketPool(RpcPacketPool pktPool)

Set the packet pool

Parameters:

pktPool - RpcPacketPool

setThreadPool

public final void setThreadPool(int numThreads)

Set the thread pool size

Parameters:

numThreads - int

setThreadPool

public final void setThreadPool(RpcRequestThreadPool threadPool)

Set the thread pool

Parameters:

threadPool - RpcRequestThreadPool