libmuscle.mcp package

Subpackages

• libmuscle.mcp.test package
  • Submodules
    • libmuscle.mcp.test.conftest module
    • libmuscle.mcp.test.test_tcp_transport module
      • test_tcp_transport()
    • libmuscle.mcp.test.test_tcp_transport_server module
      • test_create()
      • test_location()
      • test_request()

Submodules

• libmuscle.mcp.protocol module
  • RequestType
    • RequestType.DEREGISTER_INSTANCE
    • RequestType.GET_CHECKPOINT_INFO
    • RequestType.GET_NEXT_MESSAGE
    • RequestType.GET_PEERS
    • RequestType.GET_SETTINGS
    • RequestType.REGISTER_INSTANCE
    • RequestType.SUBMIT_LOG_MESSAGE
    • RequestType.SUBMIT_PROFILE_EVENTS
    • RequestType.SUBMIT_SNAPSHOT
  • ResponseType
    • ResponseType.ERROR
    • ResponseType.PENDING
    • ResponseType.SUCCESS
• libmuscle.mcp.tcp_transport_client module
  • TcpTransportClient
    • TcpTransportClient.call()
    • TcpTransportClient.can_connect_to()
    • TcpTransportClient.close()
• libmuscle.mcp.tcp_transport_server module
  • TcpHandler
    • TcpHandler.finish()
    • TcpHandler.handle()
    • TcpHandler.receive_request()
  • TcpTransportServer
    • TcpTransportServer.close()
    • TcpTransportServer.get_location()
  • TcpTransportServerImpl
    • TcpTransportServerImpl.allow_reuse_address
    • TcpTransportServerImpl.daemon_threads
• libmuscle.mcp.tcp_util module
  • SocketClosed
  • recv_all()
  • recv_int64()
  • send_int64()
• libmuscle.mcp.transport_client module
  • TransportClient
    • TransportClient.call()
    • TransportClient.can_connect_to()
    • TransportClient.close()
• libmuscle.mcp.transport_server module
  • RequestHandler
    • RequestHandler.close()
    • RequestHandler.handle_request()
  • ServerNotSupported
  • TransportServer
    • TransportServer.close()
    • TransportServer.get_location()
• libmuscle.mcp.type_registry module