All Packages  Class Hierarchy  This Package  Previous  Next  Index

Class iceberg.APCpath.services.ConnectorMgr

java.lang.Object
   |
   +----ninja.rmi.NinjaRemoteObject
           |
           +----ninja.ispace.iSpaceService
                   |
                   +----iceberg.APCpath.services.ConnectorMgr

public class ConnectorMgr

extends iSpaceService

implements ConnectorMgrIF

MYNAME

OPBASECLASS

opTable

ConnectorMgr()

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

destroy()

getOperatorDescr(String)

init(iSpaceServiceConfig)

in ispace.cfg file, add a list of operators to be loaded, create operator descriptions

initSockOp(int, DescrOperator, OperatorIF)

isOperatorAvailable(String)

listOperators()

loadLocal(int, DescrOperator)

loadLocalOperator(int, DescrOperator, String, String)

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

loadLocalOperator(String)

loads an operator from a local XML Description

loadOperator(URL)

loads the code for an operator from a given URL

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.

restartConn(int, OperatorIF, OperatorIF)

setAPCService(APCIF)

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

startRunOp(OperatorIF, DescrOperator)

terminateConn(int, OperatorIF)

 public static final String MYNAME

 protected static final String OPBASECLASS

 protected Hashtable opTable

 public ConnectorMgr() throws RemoteException

 public void init(iSpaceServiceConfig config)

in ispace.cfg file, add a list of operators to be loaded, create operator descriptions

Overrides:

init in class iSpaceService

 public void destroy()

Overrides:

destroy in class iSpaceService

 public void loadLocal(int pathid,
                       DescrOperator thedescr) throws ClassNotFoundException, IllegalArgumentException, IOException, RemoteException

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

 public 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 void loadLocalOperator(String filename) throws ClassNotFoundException, IllegalArgumentException, IOException

loads an operator from a local XML Description

 public void loadOperator(URL xmlurl) throws ClassNotFoundException, IOException, IllegalArgumentException, RemoteException

loads the code for an operator from a given URL

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

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

 public DescrOperator[] listOperators()

 public boolean isOperatorAvailable(String name)

 public DescrOperator getOperatorDescr(String name)

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

opDest is the Reader, the destination of the data flow

 public synchronized 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 void terminateConn(int connType,
                           OperatorIF op) throws IOException

 public void restartConn(int connType,
                         OperatorIF op1,
                         OperatorIF op2) throws RemoteException, IOException

 public void startRunOp(OperatorIF op,
                        DescrOperator descr) throws IOException, RemoteException

 public 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 void setAPCService(APCIF apc) throws IOException, RemoteException

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

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

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

All Packages  Class Hierarchy  This Package  Previous  Next  Index