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

Version:

beta-4, 12.8.96

Author:

Mehdi Nassehi

ChannelServicePointThread(ComPoint, long, long, long)

creates a service-point thread.

openResponderChannel(Vector, String)

open a channel as responder.

openResponderChannel(Vector, String, long)

Open a channel as responder.

run()

main body of ChannelServicePointThread.

  public 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.

  public void run()

main body of ChannelServicePointThread.

Overrides:

run in class Thread

  public ComPoint openResponderChannel(Vector options,
                                       String correlator) throws ChannelException, ChannelTimeOutException

open a channel as responder. Parameters that are single element arrays are used to pass basic types by reference. (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.

  public ComPoint openResponderChannel(Vector options,
                                       String correlator,
                                       long TimeOut) throws ChannelException, ChannelTimeOutException

Open a channel as responder. Parameters that are single element arrays are used to pass basic types by reference. (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

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.

All Packages  Class Hierarchy  This Package  Previous  Next  Index