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, timeout, 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
 
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
 
_close(self, force, timeout)
Close worker.		 source code
 
_handle_read(self)
Engine is telling us a read is available.		 source code
 
last_read(self)
Read last msg, useful in an EventHandler.		 source code
 
_on_msgline(self, msg)
Add a message.		 source code
 
_on_timeout(self)
Update on timeout.		 source code
 
read(self)
Read worker 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: abort

Inherited from EngineClient.EngineClient (private): _close_writer, _exec_nonblock, _fire, _handle_write, _readlines, _set_reading, _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

Inherited from Worker (private): _invoke, _set_task

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, timeout, 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: Worker._start

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

_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 a read is available.

Overrides: EngineClient.EngineClient._handle_read

last_read(self)

source code 

Read last msg, useful in an EventHandler.

Overrides: Worker.last_read

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 Wed Nov 4 13:58:06 2009 http://epydoc.sourceforge.net