atomic_p2p.mixin.topology.lan.handler package

Submodules

atomic_p2p.mixin.topology.lan.handler.ack_new_member module

class atomic_p2p.mixin.topology.lan.handler.ack_new_member.AckNewMemberHandler(peer)

Bases: atomic_p2p.communication.handler.Handler

on_recv_pkt(src, pkt, conn)
on_send_pkt(target)
pkt_type = 'peer-ack-new-memeber'

atomic_p2p.mixin.topology.lan.handler.check_join module

class atomic_p2p.mixin.topology.lan.handler.check_join.CheckJoinHandler(peer)

Bases: atomic_p2p.communication.handler.Handler

on_recv_pkt(src, pkt, conn)
on_send_pkt(target)
pkt_type = 'peer-checkjoin'

atomic_p2p.mixin.topology.lan.handler.disconnect module

class atomic_p2p.mixin.topology.lan.handler.disconnect.DisconnectHandler(peer)

Bases: atomic_p2p.communication.handler.Handler

on_recv_pkt(src, pkt, conn)
on_send_pkt(target)
pkt_type = 'peer-disconnect'
post_send(pkt, sock)

atomic_p2p.mixin.topology.lan.handler.join module

class atomic_p2p.mixin.topology.lan.handler.join.JoinHandler(peer)

Bases: atomic_p2p.communication.handler.Handler

on_recv_pkt(src, pkt, conn)
on_send_pkt(target)
pkt_type = 'peer-join'
post_send(pkt, sock)

atomic_p2p.mixin.topology.lan.handler.new_member module

class atomic_p2p.mixin.topology.lan.handler.new_member.NewMemberHandler(peer)

Bases: atomic_p2p.communication.handler.Handler

on_recv_pkt(src, pkt, conn)
on_send_pkt(target, peer_info)
pkt_type = 'peer-new-member'

Module contents

class atomic_p2p.mixin.topology.lan.handler.JoinHandler(peer)

Bases: atomic_p2p.communication.handler.Handler

on_recv_pkt(src, pkt, conn)
on_send_pkt(target)
pkt_type = 'peer-join'
post_send(pkt, sock)
class atomic_p2p.mixin.topology.lan.handler.CheckJoinHandler(peer)

Bases: atomic_p2p.communication.handler.Handler

on_recv_pkt(src, pkt, conn)
on_send_pkt(target)
pkt_type = 'peer-checkjoin'
class atomic_p2p.mixin.topology.lan.handler.NewMemberHandler(peer)

Bases: atomic_p2p.communication.handler.Handler

on_recv_pkt(src, pkt, conn)
on_send_pkt(target, peer_info)
pkt_type = 'peer-new-member'
class atomic_p2p.mixin.topology.lan.handler.AckNewMemberHandler(peer)

Bases: atomic_p2p.communication.handler.Handler

on_recv_pkt(src, pkt, conn)
on_send_pkt(target)
pkt_type = 'peer-ack-new-memeber'
class atomic_p2p.mixin.topology.lan.handler.DisconnectHandler(peer)

Bases: atomic_p2p.communication.handler.Handler

on_recv_pkt(src, pkt, conn)
on_send_pkt(target)
pkt_type = 'peer-disconnect'
post_send(pkt, sock)