All Packages  Class Hierarchy  This Package  Previous  Next  Index

Class ncsa.habanero.streams.CollobjRegStreams 

java.lang.Object
   |
   +----ncsa.habanero.streams.CollobjRegStreams
public class CollobjRegStreams
extends Object
CollobjRegStreams Registered the collobject's streams, keeps a store and returns tagged streams for replay

Variable Index

o parent
o socketList

Constructor Index

o CollobjRegStreams(Collobject)

Method Index

o finishCapture()
o informNewObserver(ObserverFactory, CaptureReplaySocket)
o informNewObserver(ObserverFactory, SplitterMStr)
o informNewObserver(ObserverFactory, SplitterStr)
o informObservers(CaptureReplaySocket)
o informObservers(SplitterMStr)
o informObservers(SplitterStr)
o queryNextReplayStreams(String)
o querySplitterInputStream(InputStream, String)
o querySplitterMarshallInputStream(MarshallInput, String)
o querySplitterMarshallOutputStream(MarshallOutput, String)
o querySplitterOutputStream(OutputStream, String)
o queryTaggedStream(String)
o registerSocket(CaptureReplaySocket)
o startCapture(Object, ObserverFactory)

Variables

o parent 
 protected transient Collobject parent
o socketList 
 protected transient Vector socketList

Constructors

o CollobjRegStreams 
 public CollobjRegStreams(Collobject co)
Parameters:
co - the collobject
Returns:
creates and initializes the object

Methods

o startCapture 
 public boolean startCapture(Object key,
                             ObserverFactory newFactory)
Parameters:
key - the new key
newFactory - the new factory that generates recording streams
Returns:
true if we are able to start recording (first thing recorded is the state of the collobject)
o finishCapture 
 public void finishCapture()
Returns:
stop capturing data
o registerSocket 
 public void registerSocket(CaptureReplaySocket habSock)
Parameters:
habSock - the socket that we are registering
Returns:
keeps a list of this socket and starts it recording if the collobject is alrady being read
o querySplitterMarshallOutputStream 
 public SplitterMOStr querySplitterMarshallOutputStream(MarshallOutput out,
                                                        String strTag)
Parameters:
out - the initial output stream
strTag - the tag for the object
Returns:
a new splitter stream
o querySplitterMarshallInputStream 
 public SplitterMIStr querySplitterMarshallInputStream(MarshallInput in,
                                                       String strTag)
Parameters:
in - the initial input stream
strTag - the tag for the object
Returns:
a new splitter stream
o querySplitterOutputStream 
 public SplitterOutStr querySplitterOutputStream(OutputStream out,
                                                 String strTag)
Parameters:
out - the initial output stream
strTag - the tag for the object
Returns:
a new splitter stream
o querySplitterInputStream 
 public SplitterInStr querySplitterInputStream(InputStream in,
                                               String strTag)
Parameters:
in - the initial input stream
strTag - the tag for the object
Returns:
a new splitter stream
o informObservers 
 protected void informObservers(CaptureReplaySocket res)
Parameters:
res - the socket
Returns:
inform observers about a capture replay socket
o informObservers 
 protected void informObservers(SplitterMStr res)
Parameters:
res - the stream
Returns:
inform observers about a splitter stream
o informObservers 
 protected void informObservers(SplitterStr res)
Returns:
inform observers about a splitter stream
o informNewObserver 
 protected void informNewObserver(ObserverFactory sessionFactory,
                                  CaptureReplaySocket res)
Parameters:
sessionFactory - the new observer
res - the socket
Returns:
inform observers about a capture replay socket
o informNewObserver 
 protected void informNewObserver(ObserverFactory sessionFactory,
                                  SplitterMStr res)
Parameters:
sessionFactory - the new observer
res - the stream
Returns:
inform observers about a splitter stream
o informNewObserver 
 protected void informNewObserver(ObserverFactory sessionFactory,
                                  SplitterStr res)
Parameters:
sessionFactory - the new observer
res - the stream
Returns:
inform observers about a splitter stream
o queryNextReplayStreams 
 public TimedMergingInStr queryNextReplayStreams(String strTag) throws HabaneroException
Returns:
creates a time merged str containing the socket's last two inputs
Throws: HabaneroException
when unable to open any streams
o queryTaggedStream 
 protected TimedMergingInStr queryTaggedStream(String strTag) throws HabaneroException
Returns:
creates a time merged str containing the socket's last two inputs
Throws: HabaneroException
when unable to open any streams 
All Packages  Class Hierarchy  This Package  Previous  Next  Index