quamj.qps.plugins.oci_qiop
Class Binding

java.lang.Object
  |
  +--quamj.qps.plugins.oci_qiop.Binding

public class Binding

extends java.lang.Object

Field Summary

static int	BEGIN
static int	CLIENT
static int	eEXPIRED
static int	eINIT_COMPLETED
static int	eINIT_FAILD
static int	eINITIALIZE
static int	eRESERVE_QOS
static int	eStCh_SUCC
static int	eStCh_UNSUCC
static int	eSTOPPING_COMPL
static int	eTEAR
static int	INITIALIZED
static int	INITIALIZING
static java.lang.String	LOCAL_DELAY_KEY
static java.lang.String	LOCAL_MESSAGE_SIZE_KEY
static java.lang.String	LOCAL_NUMBER_OF_INVOCATIONS_KEY
static java.lang.String	LOCAL_TIME_INTERVAL_KEY
static int	MAX_EVENT_VALUE
static int	MIN_EVENT_VALUE
ReceiverStateMachine	ReceiverSM
static java.lang.String	REMOTE_DELAY_KEY
static java.lang.String	REMOTE_MESSAGE_SIZE_KEY
static java.lang.String	REMOTE_NUMBER_OF_INVOCATIONS_KEY
static java.lang.String	REMOTE_TIME_INTERVAL_KEY
protected java.util.Properties	reservationProperties
SenderStateMachine	SenderSM
static int	SERVER
static int	STOPPED
static int	STOPPING
static int	SUCCESSFUL
Transport_impl	transport_
static int	UNSUCCESSFUL
static int	WAITING

Constructor Summary

protected

Binding(int binding_type, org.omg.CORBA.ORB orb) A new Binding can olny be created with the help fo the create_for_client or create_for_server factory methods

Method Summary

void	addTrafficListener(quamj.qps.control.SensorCollector sensor_listener)
static Binding	create_for_client(org.omg.CORBA.ORB orb, ConFactory_impl conFactory, org.omg.CORBA.Object obj) A Factory Method used from the client in way to setup a new bilateral RSVP aware connection between this corba client and its server.
static Binding	create_for_server(org.omg.CORBA.ORB orb, Transport_impl transport) The Acceptor::accept() uses this factory method (create_for_server) to create a new Binding that is assosiated with the new connection.
void	EXPIRED()
void	finalize()
java.lang.String	getReservationProperty(java.lang.String key)
com.ooc.OCI.Connector	getRsvpConnector() Used form ConFactory's create_connectors() method
boolean	INITIALIZE(java.util.Properties paramProps) State machine INITIALIZE event
static void	installRSVPDataFillerStrategy()
java.lang.String	local_host_and_port()
void	removeTrafficListener()
boolean	RESERVE_QOS(java.lang.String[] params) IMPORTANT: To avoid some synchronious porblems the distributed negotiation process should be divided in two phases: (A)neg.
void	StCh_SUCC()
void	StCh_UNSUCC()
void	STOPPING_COMPL()
void	TEAR()

Methods inherited from class java.lang.Object

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

Field Detail

CLIENT

public static final int CLIENT

See Also:

Constant Field Values

SERVER

public static final int SERVER

See Also:

Constant Field Values

transport_

public Transport_impl transport_

LOCAL_DELAY_KEY

public static final java.lang.String LOCAL_DELAY_KEY

See Also:

Constant Field Values

LOCAL_NUMBER_OF_INVOCATIONS_KEY

public static final java.lang.String LOCAL_NUMBER_OF_INVOCATIONS_KEY

See Also:

Constant Field Values

LOCAL_TIME_INTERVAL_KEY

public static final java.lang.String LOCAL_TIME_INTERVAL_KEY

See Also:

Constant Field Values

LOCAL_MESSAGE_SIZE_KEY

public static final java.lang.String LOCAL_MESSAGE_SIZE_KEY

See Also:

Constant Field Values

REMOTE_DELAY_KEY

public static final java.lang.String REMOTE_DELAY_KEY

See Also:

Constant Field Values

REMOTE_NUMBER_OF_INVOCATIONS_KEY

public static final java.lang.String REMOTE_NUMBER_OF_INVOCATIONS_KEY

See Also:

Constant Field Values

REMOTE_TIME_INTERVAL_KEY

public static final java.lang.String REMOTE_TIME_INTERVAL_KEY

See Also:

Constant Field Values

REMOTE_MESSAGE_SIZE_KEY

public static final java.lang.String REMOTE_MESSAGE_SIZE_KEY

See Also:

Constant Field Values

reservationProperties

protected java.util.Properties reservationProperties

BEGIN

public static final int BEGIN

See Also:

Constant Field Values

INITIALIZED

public static final int INITIALIZED

See Also:

Constant Field Values

INITIALIZING

public static final int INITIALIZING

See Also:

Constant Field Values

SUCCESSFUL

public static final int SUCCESSFUL

See Also:

Constant Field Values

UNSUCCESSFUL

public static final int UNSUCCESSFUL

See Also:

Constant Field Values

WAITING

public static final int WAITING

See Also:

Constant Field Values

STOPPING

public static final int STOPPING

See Also:

Constant Field Values

STOPPED

public static final int STOPPED

See Also:

Constant Field Values

MIN_EVENT_VALUE

public static final int MIN_EVENT_VALUE

See Also:

Constant Field Values

eINITIALIZE

public static final int eINITIALIZE

See Also:

Constant Field Values

eINIT_COMPLETED

public static final int eINIT_COMPLETED

See Also:

Constant Field Values

eINIT_FAILD

public static final int eINIT_FAILD

See Also:

Constant Field Values

eRESERVE_QOS

public static final int eRESERVE_QOS

See Also:

Constant Field Values

eStCh_SUCC

public static final int eStCh_SUCC

See Also:

Constant Field Values

eStCh_UNSUCC

public static final int eStCh_UNSUCC

See Also:

Constant Field Values

eTEAR

public static final int eTEAR

See Also:

Constant Field Values

eEXPIRED

public static final int eEXPIRED

See Also:

Constant Field Values

eSTOPPING_COMPL

public static final int eSTOPPING_COMPL

See Also:

Constant Field Values

MAX_EVENT_VALUE

public static final int MAX_EVENT_VALUE

See Also:

Constant Field Values

ReceiverSM

public ReceiverStateMachine ReceiverSM

SenderSM

public SenderStateMachine SenderSM

Constructor Detail

Binding

protected Binding(int binding_type,
                  org.omg.CORBA.ORB orb)

A new Binding can olny be created with the help fo the create_for_client or create_for_server factory methods

Method Detail

installRSVPDataFillerStrategy

public static void installRSVPDataFillerStrategy()

create_for_client

public static Binding create_for_client(org.omg.CORBA.ORB orb,
                                        ConFactory_impl conFactory,
                                        org.omg.CORBA.Object obj)

A Factory Method used from the client in way to setup a new bilateral RSVP aware connection between this corba client and its server. (used in the ClientResourceWrapper_impl.bindObject() mehtod) The new created Binding is registered automatically in the BindingDictionary collection.

getRsvpConnector

public com.ooc.OCI.Connector getRsvpConnector()

Used form ConFactory's create_connectors() method

create_for_server

public static Binding create_for_server(org.omg.CORBA.ORB orb,
                                        Transport_impl transport)

The Acceptor::accept() uses this factory method (create_for_server) to create a new Binding that is assosiated with the new connection.

local_host_and_port

public java.lang.String local_host_and_port()

getReservationProperty

public java.lang.String getReservationProperty(java.lang.String key)

INITIALIZE

public boolean INITIALIZE(java.util.Properties paramProps)

State machine INITIALIZE event

Returns:

If both the Sender and the Receiver are successully initialized return TRUE otherwise return FALSE. IMPORTANT: The Generic Negotiator should call the method below prior the real reseravtion method is called

RESERVE_QOS

public boolean RESERVE_QOS(java.lang.String[] params)

IMPORTANT: To avoid some synchronious porblems the distributed negotiation process should be divided in two phases: (A)neg. initaialization (i.e. the INITIALIZE() mehtod above) GNegotiator->ClinetWrapper->Biniding->INITIALIZE(); GNegotiator->SeverWrapper->Biniding->INITIALIZE(); (B)real reservations. GNegotiator->ClientWrapper->Biniding->RESERVER_QOS(); GNegotiator->ServerWrapper->Biniding->RESERVER_QOS();

Parameters:

params - are produced by mappers and are used to fill in the RSVP's TSpec and RSpec

StCh_SUCC

public void StCh_SUCC()

StCh_UNSUCC

public void StCh_UNSUCC()

TEAR

public void TEAR()

EXPIRED

public void EXPIRED()

STOPPING_COMPL

public void STOPPING_COMPL()

addTrafficListener

public void addTrafficListener(quamj.qps.control.SensorCollector sensor_listener)

removeTrafficListener

public void removeTrafficListener()

finalize

public void finalize()
              throws java.lang.Throwable

Overrides:

finalize in class java.lang.Object

java.lang.Throwable