sfi.director.invoker.Recorder Class Reference

List of all members.

Detailed Description

The recorder records jobs in a queue directory and plays them back on demand.

All the job data (job input files) is stored within the queue directory, the output files are redirected to dummy files, the target host is always the replaying host. Therefore the queue directory can be copied to an arbitrary host and will play back.

The record() method recording jobs is called from the InvokerManager whenever a job is invoked on a host having the

sfirecorderdir
attribute set. The replay() method is called by the cli.replay class.

See also:
InvokerManager

sfi.director.cli.replay

record(RemoteJob)

replay()


Public Member Functions

 Recorder (String directory) throws DirectorException
void record (RemoteJob job) throws DirectorException
synchronized void record (DBObject jobdbo) throws DirectorException
void replay () throws DirectorException

Protected Member Functions

String getBaseName ()
void incrementSeq () throws DirectorException
String infile (String url) throws DirectorException
void executeJob (String jobfile) throws DirectorException, IOException

Package Attributes

String queuedir
Hashtable fileTranslations
int seq = 0


Constructor & Destructor Documentation

sfi.director.invoker.Recorder.Recorder String  directory  )  throws DirectorException
 


Member Function Documentation

void sfi.director.invoker.Recorder.executeJob String  jobfile  )  throws DirectorException, IOException [protected]
 

String sfi.director.invoker.Recorder.getBaseName  )  [protected]
 

void sfi.director.invoker.Recorder.incrementSeq  )  throws DirectorException [protected]
 

String sfi.director.invoker.Recorder.infile String  url  )  throws DirectorException [protected]
 

synchronized void sfi.director.invoker.Recorder.record DBObject  jobdbo  )  throws DirectorException
 

void sfi.director.invoker.Recorder.record RemoteJob  job  )  throws DirectorException
 

void sfi.director.invoker.Recorder.replay  )  throws DirectorException
 


Member Data Documentation

Hashtable sfi.director.invoker.Recorder.fileTranslations [package]
 

String sfi.director.invoker.Recorder.queuedir [package]
 

int sfi.director.invoker.Recorder.seq = 0 [package]
 


The documentation for this class was generated from the following file:
Generated on Sat Feb 11 01:20:21 2012 for Node Director by  doxygen 1.4.5