All Packages  Class Hierarchy  This Package  Previous  Next  Index

Interface iceberg.APCpath.operators.OperatorIF

public interface OperatorIF
extends Remote
Interface Operators must implement

Method Index

o connect(int, int, int, String, int, int)
This call is necessary for the persistent SockReadOp.
o disconnect(int)
This call is necessary for the persistent SockReadOp.
o exec()
o getInputSource()
o getMgr()
o getOpName()
o getOutputDest()
o getPathID()
o ipBlockSize()
What is the input block size?
o isRunning()
true: if the operator is running: has been started false: if operator has been stopped
o kill()
o opBlockSize()
What is the output block size?
o setInputSource(int, Object)
o setMgr(ConnectorMgrIF)
o setOpName(String)
o setOutputDest(int, Object)
o setPathID(int)
o start(DescrOperator)
o stop()
o wakeUp()

Methods

o connect 
 public abstract int connect(int pathid,
                             int srcPort,
                             int srcConnType,
                             String ipAddr,
                             int dstPort,
                             int dstConnType) throws RemoteException
This call is necessary for the persistent SockReadOp. It connects an incoming stream to an outgoing stream.

o disconnect 
 public abstract void disconnect(int pathid) throws RemoteException
This call is necessary for the persistent SockReadOp. Disconnects a connection made earlier for 'pathid'

o opBlockSize 
 public abstract int opBlockSize() throws RemoteException
What is the output block size?

o ipBlockSize 
 public abstract int ipBlockSize() throws RemoteException
What is the input block size?

o isRunning 
 public abstract boolean isRunning() throws RemoteException
true: if the operator is running: has been started false: if operator has been stopped

o exec 
 public abstract void exec() throws RemoteException
o start 
 public abstract void start(DescrOperator descrop) throws IOException, RemoteException
o stop 
 public abstract void stop() throws IOException, RemoteException
o kill 
 public abstract void kill() throws IOException, RemoteException
o setInputSource 
 public abstract void setInputSource(int connType,
                                     Object conn) throws IOException, RemoteException
o setOutputDest 
 public abstract void setOutputDest(int connType,
                                    Object conn) throws IOException, RemoteException
o getInputSource 
 public abstract Object getInputSource() throws RemoteException
o getOutputDest 
 public abstract Object getOutputDest() throws RemoteException
o setMgr 
 public abstract void setMgr(ConnectorMgrIF mgr) throws RemoteException
o getMgr 
 public abstract ConnectorMgrIF getMgr() throws RemoteException
o setOpName 
 public abstract void setOpName(String name) throws RemoteException
o getOpName 
 public abstract String getOpName() throws RemoteException
o setPathID 
 public abstract void setPathID(int ID) throws RemoteException
o getPathID 
 public abstract int getPathID() throws RemoteException
o wakeUp 
 public abstract void wakeUp() throws RemoteException

All Packages  Class Hierarchy  This Package  Previous  Next  Index