sfi.director.invoker.StreamConnection Class Reference

List of all members.

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.
Package Attributes
InputStream	in
byte	inputbuffer [] = new byte[16384]
OutputStream	out
RemoteJob	job
StoppableThread	commander = null
StoppableThread	sender
StoppableThread	receiver
Thread	master
boolean	working
int	commands_to_complete = 0
int	commands_failed = 0
DirectorException	result = null
boolean	jobdone = false
StoppableThread	bgexe = null
long	watchdog
long	keepalive
pusher	inline_out
popper	inline_in
byte	inlinebuf []
Object	cmd_lock = new Object()
StringBuffer	_linebuf = new StringBuffer()
Static Package Attributes
static final String	transferEncoding = "utf8"
Classes
class	popper
class	pusher

---

Constructor & Destructor Documentation

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

---

Member Function Documentation

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

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

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

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

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

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

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

This implements the ServerConnection log method.

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

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

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

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

This implements the ServerConnection retrieve method.

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

This implements the ServerConnection send method.

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

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

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

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

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

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

---

Member Data Documentation

StringBuffer sfi.director.invoker.StreamConnection._linebuf = new StringBuffer() [package]

StoppableThread sfi.director.invoker.StreamConnection.bgexe = null [package]

Object sfi.director.invoker.StreamConnection.cmd_lock = new Object() [package]

StoppableThread sfi.director.invoker.StreamConnection.commander = null [package]

int sfi.director.invoker.StreamConnection.commands_failed = 0 [package]

int sfi.director.invoker.StreamConnection.commands_to_complete = 0 [package]

InputStream sfi.director.invoker.StreamConnection.in [package]

popper sfi.director.invoker.StreamConnection.inline_in [package]

pusher sfi.director.invoker.StreamConnection.inline_out [package]

byte sfi.director.invoker.StreamConnection.inlinebuf[] [package]

byte sfi.director.invoker.StreamConnection.inputbuffer[] = new byte[16384] [package]

RemoteJob sfi.director.invoker.StreamConnection.job [package]

boolean sfi.director.invoker.StreamConnection.jobdone = false [package]

long sfi.director.invoker.StreamConnection.keepalive [package]

Thread sfi.director.invoker.StreamConnection.master [package]

OutputStream sfi.director.invoker.StreamConnection.out [package]

StoppableThread sfi.director.invoker.StreamConnection.receiver [package]

DirectorException sfi.director.invoker.StreamConnection.result = null [package]

StoppableThread sfi.director.invoker.StreamConnection.sender [package]

final String sfi.director.invoker.StreamConnection.transferEncoding = "utf8" [static, package]

long sfi.director.invoker.StreamConnection.watchdog [package]

boolean sfi.director.invoker.StreamConnection.working [package]

---

The documentation for this class was generated from the following file:

• director/invoker/StreamConnection.java

---