dist.in_dist_protocol module¶
The module implements incoming TCP distribution protocol (i.e. initiated by another node with the help of EPMD). Protocol only performs handling of incoming data, the socket is handled by the Async Engine (pyrlang.async).
-
class
pyrlang.dist.in_dist_protocol.
InDistProtocol
(node_name: str, engine: pyrlang.async_support.base_engine.BaseEngine)¶ Bases:
pyrlang.dist.base_dist_protocol.BaseDistProtocol
Protocol handles incoming connections from other nodes.
-
on_connection_lost
()¶ Handler is called when the client has disconnected
-
on_packet
(data) → bool¶ Handle incoming distribution packet
Parameters: data -- The packet after the header had been removed
-
on_packet_challengereply
(data)¶
-
on_packet_recvname
(data) → bool¶ Handle RECV_NAME command, the first packet in a new connection.
-