All Packages  Class Hierarchy  This Package  Previous  Next  Index

Interface iceberg.APCpath.services.ConnectorMgrIF

public interface ConnectorMgrIF

extends Remote

cleanUp(int, OperatorIF, String)

cleaning up the data structures related to this operator of a particular path with pathid, and for a given operator op.

createEndConn(int, OperatorIF, int)

opDest is the Reader, the destination of the data flow

createOperator(int, String)

creates an operator for the path with a given pathID, the operator's class name is given as "name".

createStartConn(int, OperatorIF, InetAddress, int, String)

createStartConn: opsource is the writer, the source of the data flow

initSockOp(int, DescrOperator, OperatorIF)

not really useful, used for testing special sock operators.

loadLocalOperator(int, DescrOperator, String, String)

loadLocalOperator: load the operator with given name, create an instance, set its CM, return the operator instance.

notifyInputFailure(String, int)

notifies the APC service that the operator with given name can no longer read input data, the input pipe for that operator is broken! just call repairPath of the APCIF.

notifyOutputFailure(String, int)

notifies the APC service that the operator with given name can no longer output its data, the output pipe for that operator is broken! just call repairPath of the APCIF.

setAPCService(APCIF)

let the connection manager remember the APC service that oversees this connection manager

 public abstract OperatorIF createOperator(int pathid,
                                           String name) throws IllegalArgumentException, IllegalAccessException, InstantiationException, ClassNotFoundException, RemoteException

creates an operator for the path with a given pathID, the operator's class name is given as "name".

 public abstract int initSockOp(int pathid,
                                DescrOperator dLast,
                                OperatorIF opLast) throws RemoteException

not really useful, used for testing special sock operators.

 public abstract OperatorIF loadLocalOperator(int pathid,
                                              DescrOperator thedescr,
                                              String name,
                                              String sessionID) throws ClassNotFoundException, IllegalArgumentException, InstantiationException, IllegalAccessException, IOException, RemoteException

loadLocalOperator: load the operator with given name, create an instance, set its CM, return the operator instance.

 public abstract ConnEntry createEndConn(int connType,
                                         OperatorIF opDest,
                                         int port) throws RemoteException, IOException

opDest is the Reader, the destination of the data flow

 public abstract ConnEntry createStartConn(int connType,
                                           OperatorIF opSource,
                                           InetAddress addr,
                                           int port,
                                           String sessionID) throws RemoteException, IOException

createStartConn: opsource is the writer, the source of the data flow

 public abstract void cleanUp(int pathid,
                              OperatorIF op,
                              String sessionID) throws RemoteException

cleaning up the data structures related to this operator of a particular path with pathid, and for a given operator op.

 public abstract void setAPCService(APCIF apc) throws IOException, RemoteException

let the connection manager remember the APC service that oversees this connection manager

 public abstract void notifyInputFailure(String name,
                                         int pathID) throws IOException, RemoteException

notifies the APC service that the operator with given name can no longer read input data, the input pipe for that operator is broken! just call repairPath of the APCIF.

 public abstract void notifyOutputFailure(String name,
                                          int pathID) throws IOException, RemoteException

notifies the APC service that the operator with given name can no longer output its data, the output pipe for that operator is broken! just call repairPath of the APCIF.

All Packages  Class Hierarchy  This Package  Previous  Next  Index