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.