Package ClusterShell :: Module Gateway :: Class GatewayChannel
[hide private]
[frames] | no frames]

Class GatewayChannel

source code


high level logic for gateways

Instance Methods [hide private]
 
__init__(self, task)
x.__init__(...) initializes x; see help(type(x)) for signature
source code
 
start(self)
initialization
source code
 
close(self)
close gw channel
source code
 
recv(self, msg)
handle incoming message
source code
 
recv_cfg(self, msg)
receive cfg/topology configuration
source code
 
recv_ctl(self, msg)
receive control message with actions to perform
source code
 
_ack(self, msg)
acknowledge a received message
source code
 
ev_close(self, worker)
Gateway (parent) channel is closing.
source code

Inherited from Communication.Channel: ev_read, ev_start, send

Inherited from Communication.Channel (private): _close, _init, _open

Inherited from Event.EventHandler: ev_error, ev_hup, ev_msg, ev_pickup, ev_timeout, ev_timer, ev_written

Inherited from Event.EventHandler (private): _ev_routing

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

Class Variables [hide private]

Inherited from Communication.Channel: SNAME_ERROR, SNAME_READER, SNAME_WRITER

Properties [hide private]

Inherited from object: __class__

Method Details [hide private]

__init__(self, task)
(Constructor)

source code 

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

Overrides: object.__init__
(inherited documentation)

start(self)

source code 

initialization

Overrides: Communication.Channel.start

recv(self, msg)

source code 

handle incoming message

Overrides: Communication.Channel.recv

ev_close(self, worker)

source code 

Gateway (parent) channel is closing.

We abort the whole gateway task to stop other running workers. This avoids any unwanted remaining processes on gateways.

Overrides: Event.EventHandler.ev_close