Class semper.comm.ChannelServicePointThread
All Packages  Class Hierarchy  This Package  Previous  Next  Index

Class semper.comm.ChannelServicePointThread

java.lang.Object
   |
   +----java.lang.Thread
           |
           +----semper.comm.ChannelServicePointThread

public class ChannelServicePointThread
extends Thread
implements ComPointConstants
Defines a channel-service-point thread.
Version:
beta-4, 12.8.96
Author:
Mehdi Nassehi

Variable Index

 o address
 o blockedOpenTable
 o cleanerThread
 o cleaningPeriod
 o defaultResponderOpenTimeOut
 o maxConsExp
 o outstandingChannelTable
 o outstandingChannelTimeOut
 o serverComPoint

Constructor Index

 o ChannelServicePointThread(ComPoint, long, long, long)
creates a service-point thread.

Method Index

 o openResponderChannel(Vector, String)
open a channel as responder.
 o openResponderChannel(Vector, String, long)
Open a channel as responder.
 o run()
main body of ChannelServicePointThread.

Variables

 o serverComPoint
  protected ComPoint serverComPoint
 o address
  protected ComPointAddress address
 o outstandingChannelTimeOut
  protected long outstandingChannelTimeOut
 o defaultResponderOpenTimeOut
  protected long defaultResponderOpenTimeOut
 o cleaningPeriod
  protected long cleaningPeriod
 o blockedOpenTable
  protected Hashtable blockedOpenTable
 o outstandingChannelTable
  protected Hashtable outstandingChannelTable
 o cleanerThread
  protected ChannelCleanerThread cleanerThread
 o maxConsExp
  protected static int maxConsExp

Constructors

 o ChannelServicePointThread
  protected ChannelServicePointThread(ComPoint serverComPoint,
                                      long outstandingChannelTimeOut,
                                      long defaultResponderOpenTimeOut,
                                      long cleaningPeriod)
creates a service-point thread.
Parameters:
serverSocket - socket of the service point
outstandingChannelTimeOut - timeout period in milliseconds, after which an unclaimed channel is discarded
defaultResponderOpenTimeOut - default timeout period in milliseconds, after which an openResponderChannel unblocks
cleaningPeriod - Period in milliseconds at which the expiry times of contexts are checked.

Methods

 o run
  public void run()
main body of ChannelServicePointThread.
Overrides:
run in class Thread
 o openResponderChannel
  public ComPoint openResponderChannel(Vector options,
                                       String correlator,
                                       long TimeOut) throws ChannelException, ChannelTimeOutException
Open a channel as responder.
Parameters:
options - a Vector (placeholder to support security options in the future (currently ignored))
correlator - correlator of the desired channel
timeOut - max time in millisecond to wait for a channel
Returns:
comPoint of the channel
Throws: ChannelException
if already this method is invoked with the same port and correlator
Throws: ChannelTimeOutException
after waiting a timeout period, no matching ComPoint had arrived.
 o openResponderChannel
  public ComPoint openResponderChannel(Vector options,
                                       String correlator) throws ChannelException, ChannelTimeOutException
open a channel as responder. (Same as the above method but with the default timeout of defaultResponderOpenTimeOut.)
Parameters:
options - a Vector (placeholder to support security options in the future (currently ignored))
correlator - correlator of the desired channel
Returns:
comPoint of the channel
Throws: ChannelException
if already this method is invoked with the same port and correlator
Throws: ChannelTimeOutException
after waiting a timeout period, no matching ComPoint had arrived.

All Packages  Class Hierarchy  This Package  Previous  Next  Index