libmuscle.mcp package

Subpackages

• libmuscle.mcp.test package
  • Submodules
    • libmuscle.mcp.test.conftest module
      • post_office()
      • receiver()
      • tcp_transport_server()
    • 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
  • AgentCommandType
    • AgentCommandType.CANCEL_ALL
    • AgentCommandType.SHUTDOWN
    • AgentCommandType.START
  • RequestType
    • RequestType.DEREGISTER_INSTANCE
    • RequestType.GET_CHECKPOINT_INFO
    • RequestType.GET_COMMAND
    • RequestType.GET_NEXT_MESSAGE
    • RequestType.GET_PEERS
    • RequestType.GET_SETTINGS
    • RequestType.IS_DEADLOCKED
    • RequestType.REGISTER_INSTANCE
    • RequestType.REPORT_RESOURCES
    • RequestType.REPORT_RESULT
    • RequestType.SUBMIT_LOG_MESSAGE
    • RequestType.SUBMIT_PROFILE_EVENTS
    • RequestType.SUBMIT_SNAPSHOT
    • RequestType.WAITING_FOR_RECEIVE
    • RequestType.WAITING_FOR_RECEIVE_DONE
  • ResponseType
    • ResponseType.ERROR
    • ResponseType.PENDING
    • ResponseType.SUCCESS
• libmuscle.mcp.session_state module
  • SessionState
    • SessionState.set_response()
    • SessionState.triage_request()
    • SessionState.wait_get_response()
• libmuscle.mcp.tcp_transport_client module
  • NoPendingResponse
  • TcpTransportClient
    • TcpTransportClient.call()
    • TcpTransportClient.can_connect_to()
    • TcpTransportClient.close()
• libmuscle.mcp.tcp_transport_server module
  • TcpHandler
    • TcpHandler.finish()
    • TcpHandler.handle()
  • TcpTransportServer
    • TcpTransportServer.close()
    • TcpTransportServer.get_location()
  • TcpTransportServerImpl
    • TcpTransportServerImpl.allow_reuse_address
    • TcpTransportServerImpl.daemon_threads
• libmuscle.mcp.tcp_util module
  • SocketClosed
  • is_disconnect()
  • recv_all()
  • recv_frame()
  • recv_int64()
  • send_frame()
  • send_int64()
• libmuscle.mcp.transport_client module
  • TimeoutHandler
    • TimeoutHandler.on_receive()
    • TimeoutHandler.on_timeout()
    • TimeoutHandler.timeout
  • 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