de::gsi::bel::xferserver::XferServerImpl

de::gsi::bel::xferserver::XferServerImpl Class Reference

Inheritance diagram for de::gsi::bel::xferserver::XferServerImpl:

de::gsi::bel::xferserver::XferServer List of all members.

Public Member Functions

 XferServerImpl (int port) throws IOException
synchronized void setOnline (boolean online)
synchronized void addXferRequestListener (XferListener listener)
synchronized void rmXferRequestListener (XferListener listener)
synchronized void close ()
final void run ()
final void exitHandler (Xfer xfer)
final void handleMessage (Object obj, Xfer xfer)
final synchronized void dispatch ()

Classes

class  ClientRequest
class  ThreadUserArg

Detailed Description

The Xfer Server listens on a TCP/IP port for incoming Xfer client connections. The client requests are queued and processed in a decoupler thread. The user adds listeners to the Xfer object to be informed about new requests. For each connection a new xfer Object is created.

Author:
huhmann

Constructor & Destructor Documentation

de::gsi::bel::xferserver::XferServerImpl::XferServerImpl ( int  port  )  throws IOException [inline]

Create an Xfer Server

Parameters:
port Port number to listen to

Member Function Documentation

synchronized void de::gsi::bel::xferserver::XferServerImpl::addXferRequestListener ( XferListener  listener  )  [inline, virtual]

Add a listener to the XferServer. The listener method handleMessage is called when an object is received. The listener method exitHandler is called when the xfer connection is closed by peer.

Parameters:
listener to add
See also:
XferListener

Implements de::gsi::bel::xferserver::XferServer.

synchronized void de::gsi::bel::xferserver::XferServerImpl::close (  )  [inline, virtual]

Shut down the server and all client connections

Implements de::gsi::bel::xferserver::XferServer.

final synchronized void de::gsi::bel::xferserver::XferServerImpl::dispatch (  )  [inline]

The dispatch-function is called by decoupler thread when the input queue was filled by one of the xfer threads. This ensures that the xfer receiver threads can still receive messages even when message listeners (which are called by the decoupler) may block for some time

synchronized void de::gsi::bel::xferserver::XferServerImpl::rmXferRequestListener ( XferListener  listener  )  [inline, virtual]

Removes a listener from the XferServer.

Parameters:
listener to remove
See also:
XferListener

Implements de::gsi::bel::xferserver::XferServer.

synchronized void de::gsi::bel::xferserver::XferServerImpl::setOnline ( boolean  online  )  [inline, virtual]

enable or disable handlers

Parameters:
online true: dispatch the message objects received false: objects are received but no handlers are called

Implements de::gsi::bel::xferserver::XferServer.

The documentation for this class was generated from the following file:
Generated on 4 Mar 2014 for xferserver by  doxygen 1.4.7