Package ClusterShell :: Package Worker :: Module Popen :: Class WorkerPopen
[hide private]
[frames] | no frames]

Class WorkerPopen

source code


Implements the Popen Worker.

Instance Methods [hide private]
 
__init__(self, command, key=None, handler=None, stderr=False, timeout=-1, autoclose=False)
Initialize Popen worker.
source code
 
_start(self)
Start worker.
source code
 
_close(self, force, timeout)
Close worker.
source code
 
_on_rc(self, rc)
Set return code.
source code
 
retcode(self)
Return return code or None if command is still in progress.
source code

Inherited from Worker.WorkerSimple: error, error_fileno, last_error, last_read, read, reader_fileno, set_key, set_write_eof, write, writer_fileno

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

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

Inherited from Worker.Worker: did_timeout, flush_buffers, flush_errors

Inherited from Worker.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, command, key=None, handler=None, stderr=False, timeout=-1, autoclose=False)
(Constructor)

source code 

Initialize Popen worker.

Overrides: object.__init__

_start(self)

source code 

Start worker.

Overrides: EngineClient.EngineClient._start

_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