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, task, gwchan, srcwkr)
(Constructor)

source code

x.__init__(...) initializes x; see help(type(x)) for signature

Overrides: object.__init__: (inherited documentation)

ev_start(self, worker)

source code

Called to indicate that a worker has just started.

:param worker: :class:`.Worker` object

Overrides: Event.EventHandler.ev_start: (inherited documentation)

ev_timer(self, timer)

source code

perform gateway traffic grooming

Overrides: Event.EventHandler.ev_timer

ev_read(self, worker)

source code

message received on stdout

Overrides: Event.EventHandler.ev_read

ev_error(self, worker)

source code

message received on stderr

Overrides: Event.EventHandler.ev_error

ev_timeout(self, worker)

source code

Received timeout event: some nodes did timeout

Overrides: Event.EventHandler.ev_timeout

ev_hup(self, worker)

source code

Received end of command from one node

Overrides: Event.EventHandler.ev_hup

ev_close(self, worker)

source code

End of CTL responder

Overrides: Event.EventHandler.ev_close

Class WorkerTreeResponder

__init__(self, task, gwchan, srcwkr) (Constructor)

ev_start(self, worker)

ev_timer(self, timer)

ev_read(self, worker)

ev_error(self, worker)

ev_timeout(self, worker)

ev_hup(self, worker)

ev_close(self, worker)

init(self, task, gwchan, srcwkr)
(Constructor)