Trees       Indices       Help   
ClusterShell
Package ClusterShell :: Package Worker :: Module Worker :: Class WorkerSimple
[hide private]
[frames] | no frames]

Class WorkerSimple

source code

Implements a simple Worker being itself an EngineClient.

Instance Methods [hide private]
 
__init__(self, file_reader, file_writer, file_error, key, handler, stderr=False, timeout=-1, autoclose=False)
Initialize worker.		 source code
 
_engine_clients(self)
Return a list of underlying engine clients.		 source code
 
set_key(self, key)
Source key for this worker is free for use.		 source code
 
_start(self)
Start worker.		 source code
 
error_fileno(self)
Returns the standard error reader file descriptor as an integer.		 source code
 
reader_fileno(self)
Returns the reader file descriptor as an integer.		 source code
 
writer_fileno(self)
Returns the writer file descriptor as an integer.		 source code
 
_read(self, size=4096)
Read data from process.		 source code
 
_readerr(self, size=4096)
Read error data from process.		 source code
 
_close(self, force, timeout)
Close worker.		 source code
 
_handle_read(self)
Engine is telling us there is data available for reading.		 source code
 
_handle_error(self)
Engine is telling us there is error available for reading.		 source code
 
last_read(self)
Read last msg, useful in an EventHandler.		 source code
 
last_error(self)
Get last error message from event handler.		 source code
 
_on_msgline(self, msg)
Add a message.		 source code
 
_on_errmsgline(self, msg)
Add a message.		 source code
 
_on_timeout(self)
Update on timeout.		 source code
 
read(self)
Read worker buffer.		 source code
 
error(self)
Read worker error buffer.		 source code
 
write(self, buf)
Write to worker.		 source code
 
set_write_eof(self)
Tell worker to close its writer file descriptor once flushed.		 source code

Inherited from EngineClient.EngineClient (private): _close_writer, _exec_nonblock, _fire, _handle_write, _readerrlines, _readlines, _set_reading, _set_reading_error, _set_write_eof, _set_writing, _write

Inherited from Engine.Engine.EngineBaseTimer: invalidate, is_valid, set_nextfire

Inherited from Engine.Engine.EngineBaseTimer (private): _set_engine

Inherited from Worker: did_timeout, flush_buffers, flush_errors

Inherited from Worker (private): _invoke, _set_task, _task_bound_check

Inherited from object: __delattr__, __format__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __repr__, __setattr__, __sizeof__, __str__, __subclasshook__

Properties [hide private]

Inherited from object: __class__

Method Details [hide private]

__init__(self, file_reader, file_writer, file_error, key, handler, stderr=False, timeout=-1, autoclose=False)
(Constructor)

source code 

Initialize worker.

Overrides: object.__init__

_engine_clients(self)

source code 

Return a list of underlying engine clients.

Overrides: Worker._engine_clients

set_key(self, key)

source code 

Source key for this worker is free for use. Use this method to set the custom source key for this worker.

_start(self)

source code 

Start worker.

Overrides: EngineClient.EngineClient._start

error_fileno(self)

source code 

Returns the standard error reader file descriptor as an integer.

Overrides: EngineClient.EngineClient.error_fileno

reader_fileno(self)

source code 

Returns the reader file descriptor as an integer.

Overrides: EngineClient.EngineClient.reader_fileno

writer_fileno(self)

source code 

Returns the writer file descriptor as an integer.

Overrides: EngineClient.EngineClient.writer_fileno

_read(self, size=4096)

source code 

Read data from process.

Overrides: EngineClient.EngineClient._read

_readerr(self, size=4096)

source code 

Read error data from process.

Overrides: EngineClient.EngineClient._readerr

_close(self, force, timeout)

source code 

Close worker. Called by engine after worker has been unregistered. This method should handle all termination types (normal, forced or on timeout).

Overrides: EngineClient.EngineClient._close

_handle_read(self)

source code 

Engine is telling us there is data available for reading.

Overrides: EngineClient.EngineClient._handle_read

_handle_error(self)

source code 

Engine is telling us there is error available for reading.

Overrides: EngineClient.EngineClient._handle_error

last_read(self)

source code 

Read last msg, useful in an EventHandler.

Overrides: Worker.last_read

last_error(self)

source code 

Get last error message from event handler.

Overrides: Worker.last_error

set_write_eof(self)

source code 

Tell worker to close its writer file descriptor once flushed. Do not perform writes after this call.


   Trees       Indices       Help   
ClusterShell
Generated by Epydoc 3.0.1 on Tue Jul 27 21:53:22 2010 http://epydoc.sourceforge.net