org.sourceforge.jemmrpc.server
Class ServerThread

java.lang.Object
  org.sourceforge.jemmrpc.server.ServerThread

All Implemented Interfaces:

RPCHandlerListener

public class ServerThread
extends java.lang.Object
implements RPCHandlerListener

ServerThread is used by RPCServer for handling individual client connections.

Author:

Rory Graves

Field Summary

protected ClientId	clientId
protected boolean	connected
protected static org.apache.log4j.Logger	LOG
protected RPCHandler	rpcHandler
protected RPCServer	server
protected java.util.concurrent.CountDownLatch	shutdownLatch
protected java.net.Socket	socket

Constructor Summary

ServerThread(RPCServer fServer, java.net.Socket fSocket, ClientId fClientId, java.util.Map<java.lang.Class<?>,java.lang.Object> fOfferedIfs, java.util.concurrent.ExecutorService fThreadPool)
Creates a server thread to handle a specific client connection.

Method Summary

void	connectionTerminated() Notification that the connection has been closed.
java.lang.Object	getClientIF(java.lang.Class<?> ifClass) Gets the proxy for the given client interface.
void	shutdown() Shutdown the thread by closing its socket connection.
void	start() Start the server thread, initialising the connection and listening to client requests.
void	waitForShutdown() Utility method to allow a thread to wait for this thread to have completely terminated.

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final org.apache.log4j.Logger LOG

shutdownLatch

protected final java.util.concurrent.CountDownLatch shutdownLatch

clientId

protected final ClientId clientId

server

protected final RPCServer server

rpcHandler

protected final RPCHandler rpcHandler

socket

protected final java.net.Socket socket

connected

protected volatile boolean connected

Constructor Detail

ServerThread

public ServerThread(RPCServer fServer,
                    java.net.Socket fSocket,
                    ClientId fClientId,
                    java.util.Map<java.lang.Class<?>,java.lang.Object> fOfferedIfs,
                    java.util.concurrent.ExecutorService fThreadPool)

Creates a server thread to handle a specific client connection.

Parameters:

fServer - The server instance this client belongs to

fSocket - The client socket

fClientId - The server assigned client id;

fOfferedIfs - The interfaces offered to the client by the server

fThreadPool - The threadpool to use for servicing requests

Method Detail

start

public void start()

Start the server thread, initialising the connection and listening to client requests.

connectionTerminated

public void connectionTerminated()

Notification that the connection has been closed.

Specified by:

connectionTerminated in interface RPCHandlerListener

shutdown

public void shutdown()

Shutdown the thread by closing its socket connection.

waitForShutdown

public void waitForShutdown()

Utility method to allow a thread to wait for this thread to have completely terminated. This method will return immediately if the thread is already stopped, otherwise it will wait until all shutdown actions have completed before returning.

getClientIF

public java.lang.Object getClientIF(java.lang.Class<?> ifClass)

Gets the proxy for the given client interface.

Parameters:

ifClass - The requesting interface implementation.

Returns:

A proxy that implements the interface 'ifClass'