org.alfresco.jlan.oncrpc

Class MultiThreadedUdpRpcDatagramHandler

java.lang.Object

org.alfresco.jlan.server.DatagramSessionHandler

org.alfresco.jlan.oncrpc.UdpRpcDatagramHandler

org.alfresco.jlan.oncrpc.MultiThreadedUdpRpcDatagramHandler

All Implemented Interfaces:

Runnable, RpcPacketHandler, SessionHandlerInterface

public class MultiThreadedUdpRpcDatagramHandler
extends UdpRpcDatagramHandler
implements RpcPacketHandler

Multi-Threaded UDP RPC Datagram Handler Class

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

Author:

gkspencer

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	MultiThreadedUdpRpcDatagramHandler.DatagramSender Datagram Sender Thread Inner Class

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected byte[]	allocateBuffer(int bufSize) Allocate a buffer for the next datagram
void	closeSessionHandler(NetworkServer server) Close the session handler
void	initializeSessionHandler(NetworkServer server) Initialize the session handler
protected boolean	processDatagram(DatagramPacket pkt) Process the RPC request
protected void	queueRpcRequest(RpcPacket rpc) Queue an RPC request to the thread pool for processing
void	sendRpcResponse(RpcPacket rpc) Send an RPC response using the datagram socket
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.UdpRpcDatagramHandler

getRpcProcessor

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

clearShutdown, getBindAddres, getDatagramSocket, getHandlerName, getMaximumDatagramSize, getNextSessionId, getPort, getProtocolName, hasBindAddress, hasDebug, hasShutdown, run, sendDatagram, setDebug, setMaximumDatagramSize, setPort

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, 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

MultiThreadedUdpRpcDatagramHandler

public MultiThreadedUdpRpcDatagramHandler(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 handler

Specified by:

initializeSessionHandler in interface SessionHandlerInterface

Overrides:

initializeSessionHandler in class DatagramSessionHandler

Parameters:

server - NetworkServer

Throws:

IOException

processDatagram

protected boolean processDatagram(DatagramPacket pkt)
                           throws IOException

Process the RPC request

Overrides:

processDatagram in class UdpRpcDatagramHandler

Parameters:

pkt - DatagramPacket

Returns:

boolean

Throws:

IOException

queueRpcRequest

protected final void queueRpcRequest(RpcPacket rpc)

Queue an RPC request to the thread pool for processing

Parameters:

rpc - RpcPacket

allocateBuffer

protected byte[] allocateBuffer(int bufSize)

Allocate a buffer for the next datagram

Overrides:

allocateBuffer in class DatagramSessionHandler

Parameters:

bufSize - int

Returns:

byte[]

sendRpcResponse

public void sendRpcResponse(RpcPacket rpc)
                     throws IOException

Send an RPC response using the datagram socket

Specified by:

sendRpcResponse in interface RpcPacketHandler

Parameters:

rpc - RpcPacket

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

closeSessionHandler

public void closeSessionHandler(NetworkServer server)

Close the session handler

Specified by:

closeSessionHandler in interface SessionHandlerInterface

Overrides:

closeSessionHandler in class DatagramSessionHandler

Parameters:

server - NetworkServer