org.alfresco.jlan.oncrpc

Class TcpRpcSessionHandler

java.lang.Object

org.alfresco.jlan.server.SessionHandlerBase

org.alfresco.jlan.server.SocketSessionHandler

org.alfresco.jlan.oncrpc.TcpRpcSessionHandler

All Implemented Interfaces:

Runnable, SessionHandlerInterface

Direct Known Subclasses:

MultiThreadedTcpRpcSessionHandler

public class TcpRpcSessionHandler
extends SocketSessionHandler

TCP RPC Session Handler Class

Receives session requests via a TCP socketRPC requests via a datagram and passes the request to the registered RPC server.

Author:

gkspencer

Field Summary

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

ListenBacklog

Constructor Summary

Constructors

Constructor and Description
TcpRpcSessionHandler(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 void	acceptConnection(Socket sock) Accept an incoming session request
protected void	closeSession(int sessId) Remove a session from the active session list
void	closeSessionHandler(NetworkServer server) Close the session handler, close all active sessions.
protected TcpRpcPacketHandler	createPacketHandler(int sessId, Socket sock) Create a packet handler for a new session
protected int	getMaximumRpcSize() Return the maximum RPC size allowed
protected RpcProcessor	getRpcProcessor() Return the RPC server used to process the requests

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

getSocket, getSocketTimeout, initializeSessionHandler, 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

Constructor Detail

TcpRpcSessionHandler

public TcpRpcSessionHandler(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

getMaximumRpcSize

protected int getMaximumRpcSize()

Return the maximum RPC size allowed

Returns:

int

getRpcProcessor

protected final RpcProcessor getRpcProcessor()

Return the RPC server used to process the requests

Returns:

RpcProcessor

acceptConnection

protected void acceptConnection(Socket sock)

Accept an incoming session request

Specified by:

acceptConnection in class SocketSessionHandler

Parameters:

sock - Socket

closeSession

protected final void closeSession(int sessId)

Remove a session from the active session list

Parameters:

sessId - int

closeSessionHandler

public void closeSessionHandler(NetworkServer server)

Close the session handler, close all active sessions.

Specified by:

closeSessionHandler in interface SessionHandlerInterface

Overrides:

closeSessionHandler in class SocketSessionHandler

Parameters:

server - NetworkServer

createPacketHandler

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

Create a packet handler for a new session

Parameters:

sessId - int

sock - Socket

Returns:

TcpRpcPacketHandler

Throws:

IOException