dist_proto.server module

The module implements incoming TCP dist_proto 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_proto.server.DistServerProtocol(node_name: str)

Bases: pyrlang.dist_proto.base_dist_protocol.BaseDistProtocol

Protocol handles incoming connections from other nodes.

connection_lost(exc)

Handler is called when the client has disconnected

on_packet(data: bytes) → bytes

Handle incoming dist_proto packet

Parameters

data -- The packet after the header had been removed

on_packet_challengereply(data: bytes) → bytes
on_packet_recvname(data: bytes) → bytes

Handle RECV_NAME command, the first packet in a new connection.