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