Node Director
Classes | Public Member Functions | Protected Member Functions | List of all members
sfi.director.invoker.StreamConnection Class Reference

Classes

class  popper
class  pusher

Public Member Functions

 StreamConnection (InputStream in, OutputStream out)
void Server (RemoteJob job) throws DirectorException
void Agent () throws DirectorException

Protected Member Functions

void leanBackAndWait () throws DirectorException
synchronized void imDone ()
String readNextLine () throws IOException
boolean commonListen (String cmd)
void masterlistener (StoppableThread thread)
void waitEvent ()
void send (byte[] buf, int offset, int size) throws IOException
void send_string (String str) throws IOException
void send_final_string (String str)
boolean send_cmd (String cmd) throws IOException
void master (StoppableThread thread)
void agentlistener (StoppableThread thread)
void agent (StoppableThread thread)
InputStream retrieve (String url) throws DirectorException
 This implements the ServerConnection retrieve method.
OutputStream send (String url) throws DirectorException
 This implements the ServerConnection send method.
void log (LogEntry log) throws DirectorException
 This implements the ServerConnection log method.

Constructor & Destructor Documentation

sfi.director.invoker.StreamConnection.StreamConnection ( InputStream  in,
OutputStream  out 
)

Member Function Documentation

void sfi.director.invoker.StreamConnection.Agent ( ) throws DirectorException

References sfi.director.invoker.StreamConnection.agent(), sfi.director.invoker.StreamConnection.agentlistener(), and sfi.director.invoker.StreamConnection.leanBackAndWait().

Referenced by sfi.director.cli.agent.run().

void sfi.director.invoker.StreamConnection.agent ( StoppableThread  thread)
protected

References sfi.director.invoker.StreamConnection.imDone(), sfi.director.util.StoppableThread.keeprunning, sfi.director.invoker.StreamConnection.send_string(), and sfi.director.invoker.StreamConnection.waitEvent().

Referenced by sfi.director.invoker.StreamConnection.Agent().

void sfi.director.invoker.StreamConnection.agentlistener ( StoppableThread  thread)
protected

References sfi.director.invoker.StreamConnection.commonListen(), sfi.director.util.Tools.debug(), sfi.director.util.Tools.debuglev, sfi.director.jobs.JobStatus.equals(), sfi.director.util.Logger.ERR, sfi.director.jobs.Job.getId(), sfi.director.util.Logger.getKey(), sfi.director.jobs.Job.getStatus(), sfi.director.invoker.StreamConnection.imDone(), sfi.director.util.Logger.INFO, sfi.director.jobs.RemoteJob.invoke(), sfi.director.util.DirectorException.isRetryable(), sfi.director.util.StoppableThread.keeprunning, sfi.director.util.Tools.log(), sfi.director.invoker.StreamConnection.log(), sfi.director.invoker.StreamConnection.readNextLine(), sfi.director.jobs.Job.reanimate(), sfi.director.invoker.StreamConnection.retrieve(), sfi.director.invoker.StreamConnection.send(), sfi.director.invoker.StreamConnection.send_string(), sfi.director.invoker.AgentLogger.setServer(), sfi.director.jobs.Job.setServer(), sfi.director.util.Tools.stacktrace(), sfi.director.jobs.JobStatus.wait, and sfi.director.util.Logger.WARNING.

Referenced by sfi.director.invoker.StreamConnection.Agent().

boolean sfi.director.invoker.StreamConnection.commonListen ( String  cmd)
protected

References sfi.director.util.Tools.debug(), sfi.director.invoker.StreamConnection.imDone(), sfi.director.util.StoppableThread.interrupt(), sfi.director.invoker.StreamConnection.send_final_string(), and sfi.director.invoker.StreamConnection.send_string().

Referenced by sfi.director.invoker.StreamConnection.agentlistener(), and sfi.director.invoker.StreamConnection.masterlistener().

synchronized void sfi.director.invoker.StreamConnection.imDone ( )
protected

References sfi.director.util.Tools.debug().

Referenced by sfi.director.invoker.StreamConnection.agent(), sfi.director.invoker.StreamConnection.agentlistener(), sfi.director.invoker.StreamConnection.commonListen(), sfi.director.invoker.StreamConnection.master(), and sfi.director.invoker.StreamConnection.masterlistener().

void sfi.director.invoker.StreamConnection.leanBackAndWait ( ) throws DirectorException
protected

References sfi.director.util.Tools.debug(), sfi.director.util.Logger.getLogger(), sfi.director.util.Tools.log(), sfi.director.util.Setup.logger, sfi.director.util.Logger.NOTICE, sfi.director.invoker.StreamConnection.send_final_string(), sfi.director.util.StoppableThread.stopGracefully(), and sfi.director.invoker.StreamConnection.waitEvent().

Referenced by sfi.director.invoker.StreamConnection.Agent(), and sfi.director.invoker.StreamConnection.Server().

void sfi.director.invoker.StreamConnection.log ( LogEntry  log) throws DirectorException
protected

This implements the ServerConnection log method.

References sfi.director.invoker.StreamConnection.send_cmd().

Referenced by sfi.director.invoker.StreamConnection.agentlistener(), and sfi.director.invoker.StreamConnection.masterlistener().

void sfi.director.invoker.StreamConnection.master ( StoppableThread  thread)
protected

References sfi.director.invoker.StreamConnection.imDone(), sfi.director.util.StoppableThread.keeprunning, sfi.director.repository.DBObject.removeAttribute(), sfi.director.invoker.StreamConnection.send_cmd(), sfi.director.util.Tools.setThreadSubStatus(), sfi.director.jobs.RemoteJob.todb(), sfi.director.repository.DBObject.toLDIF(), and sfi.director.invoker.StreamConnection.waitEvent().

void sfi.director.invoker.StreamConnection.masterlistener ( StoppableThread  thread)
protected

References sfi.director.invoker.StreamConnection.commonListen(), sfi.director.retriever.RemoteFile.connectRetrieve(), sfi.director.retriever.RemoteFile.connectSend(), sfi.director.util.Tools.debug(), sfi.director.util.Tools.debuglev, sfi.director.retriever.RetrieverManager.getConnection(), sfi.director.jobs.RemoteJob.getHost(), sfi.director.util.LogEntry.getIndent(), sfi.director.jobs.RemoteJob.getInputFile(), sfi.director.util.LogEntry.getLevel(), sfi.director.util.LogEntry.getMessage(), sfi.director.jobs.RemoteJob.getOutputFile(), sfi.director.util.LogEntry.getTime(), sfi.director.invoker.StreamConnection.imDone(), sfi.director.util.StoppableThread.interrupt(), sfi.director.util.StoppableThread.keeprunning, sfi.director.util.Tools.log(), sfi.director.invoker.StreamConnection.log(), sfi.director.invoker.StreamConnection.readNextLine(), sfi.director.invoker.StreamConnection.send_final_string(), sfi.director.invoker.StreamConnection.send_string(), sfi.director.util.Tools.setThreadSubStatus(), and sfi.director.jobs.Job.Sleep().

Referenced by sfi.director.invoker.StreamConnection.Server().

String sfi.director.invoker.StreamConnection.readNextLine ( ) throws IOException
protected

Referenced by sfi.director.invoker.StreamConnection.agentlistener(), and sfi.director.invoker.StreamConnection.masterlistener().

InputStream sfi.director.invoker.StreamConnection.retrieve ( String  url) throws DirectorException
protected

This implements the ServerConnection retrieve method.

References sfi.director.invoker.StreamConnection.send_cmd().

Referenced by sfi.director.invoker.StreamConnection.agentlistener().

void sfi.director.invoker.StreamConnection.send ( byte[]  buf,
int  offset,
int  size 
) throws IOException
protected

Referenced by sfi.director.invoker.StreamConnection.agentlistener().

OutputStream sfi.director.invoker.StreamConnection.send ( String  url) throws DirectorException
protected

This implements the ServerConnection send method.

References sfi.director.invoker.StreamConnection.send_cmd().

boolean sfi.director.invoker.StreamConnection.send_cmd ( String  cmd) throws IOException
protected

References sfi.director.util.StoppableThread.keeprunning, sfi.director.invoker.StreamConnection.send_string(), sfi.director.util.Tools.setThreadSubStatus(), and sfi.director.invoker.StreamConnection.waitEvent().

Referenced by sfi.director.invoker.StreamConnection.log(), sfi.director.invoker.StreamConnection.master(), sfi.director.invoker.StreamConnection.retrieve(), and sfi.director.invoker.StreamConnection.send().

void sfi.director.invoker.StreamConnection.send_final_string ( String  str)
protected

References sfi.director.invoker.StreamConnection.send_string().

Referenced by sfi.director.invoker.StreamConnection.commonListen(), sfi.director.invoker.StreamConnection.leanBackAndWait(), and sfi.director.invoker.StreamConnection.masterlistener().

void sfi.director.invoker.StreamConnection.send_string ( String  str) throws IOException
protected

References sfi.director.util.Tools.debug(), and sfi.director.util.Tools.debuglev.

Referenced by sfi.director.invoker.StreamConnection.agent(), sfi.director.invoker.StreamConnection.agentlistener(), sfi.director.invoker.StreamConnection.commonListen(), sfi.director.invoker.StreamConnection.masterlistener(), sfi.director.invoker.StreamConnection.send_cmd(), and sfi.director.invoker.StreamConnection.send_final_string().

void sfi.director.invoker.StreamConnection.Server ( RemoteJob  job) throws DirectorException

References sfi.director.jobs.RemoteJob.getHost(), sfi.director.invoker.StreamConnection.leanBackAndWait(), and sfi.director.invoker.StreamConnection.masterlistener().

Referenced by sfi.director.invoker.SSLInvoker.connect(), and sfi.director.invoker.StreamCmdInvoker.connect().

void sfi.director.invoker.StreamConnection.waitEvent ( )
protected

Referenced by sfi.director.invoker.StreamConnection.agent(), sfi.director.invoker.StreamConnection.leanBackAndWait(), sfi.director.invoker.StreamConnection.master(), and sfi.director.invoker.StreamConnection.send_cmd().

The documentation for this class was generated from the following file:
Generated on Sat Feb 4 2023 01:20:01 for Node Director by   doxygen 1.8.1.2