atomic_p2p package

Subpackages

• atomic_p2p.abc package
  • Submodules
  • atomic_p2p.abc.authenticator module
  • atomic_p2p.abc.topology module
  • Module contents
• atomic_p2p.communication package
  • Submodules
  • atomic_p2p.communication.command module
  • atomic_p2p.communication.handler module
  • atomic_p2p.communication.packet module
  • Module contents
• atomic_p2p.logging package
  • Submodules
  • atomic_p2p.logging.formatters module
  • atomic_p2p.logging.handlers module
  • Module contents
• atomic_p2p.manager package
  • Submodules
  • atomic_p2p.manager.process module
  • atomic_p2p.manager.thread module
  • Module contents
• atomic_p2p.mixin package
  • Subpackages
    • atomic_p2p.mixin.authenticator package
      • Submodules
      • atomic_p2p.mixin.authenticator.default_authenticator module
      • Module contents
    • atomic_p2p.mixin.topology package
      • Subpackages
        • atomic_p2p.mixin.topology.lan package
          • Subpackages
            • atomic_p2p.mixin.topology.lan.handler package
              • Submodules
              • atomic_p2p.mixin.topology.lan.handler.ack_new_member module
              • atomic_p2p.mixin.topology.lan.handler.check_join module
              • atomic_p2p.mixin.topology.lan.handler.disconnect module
              • atomic_p2p.mixin.topology.lan.handler.join module
              • atomic_p2p.mixin.topology.lan.handler.new_member module
              • Module contents
          • Module contents
      • Module contents
  • Submodules
  • atomic_p2p.mixin.commandable module
  • atomic_p2p.mixin.handleable module
  • Module contents
• atomic_p2p.peer package
  • Subpackages
    • atomic_p2p.peer.entity package
      • Submodules
      • atomic_p2p.peer.entity.peer_info module
      • atomic_p2p.peer.entity.peer_status module
      • Module contents
    • atomic_p2p.peer.monitor package
      • Submodules
      • atomic_p2p.peer.monitor.command module
      • atomic_p2p.peer.monitor.communication module
      • Module contents
  • Submodules
  • atomic_p2p.peer.command module
  • atomic_p2p.peer.communication module
  • atomic_p2p.peer.peer module
  • atomic_p2p.peer.process_peer module
  • atomic_p2p.peer.thread_peer module
  • Module contents
• atomic_p2p.utils package
  • Submodules
  • atomic_p2p.utils.dns_resolver module
  • atomic_p2p.utils.security module
  • Module contents

Submodules

atomic_p2p.local_monitor module

class atomic_p2p.local_monitor.LocalMonitor(service, password, logger=<Logger atomic_p2p.local_monitor (DEBUG)>)

Bases: atomic_p2p.manager.thread.ThreadManager

command_recv(enc_data, addr)

decrypt(enc_data)

encrypt(raw_data)

new_cipher(key)

registerCommand()

registerHandler()

run()

Method representing the thread’s activity.

You may override this method in a subclass. The standard run() method invokes the callable object passed to the object’s constructor as the target argument, if any, with sequential and keyword arguments taken from the args and kwargs arguments, respectively.

stop()

Module contents

class atomic_p2p.AtomicP2P(role, addr, name, cert, logger)

Bases: object

__init__(role, addr, name, cert, logger)

Init of AtomicP2P object :param role: str represents peer’s role. :param addr: str with ip:port format, peer server will listen on. :param name: str represents peer’s name. :param cert: str represents cert file’s path, should directly point to

cert file. like data/atomic_p2p.pem, and key file should same as cert file exception sub-extension with .key.

start()

stop()