libmuscle.mcp.tcp_transport_server module

class libmuscle.mcp.tcp_transport_server.TcpHandler(request, client_address, server)

Bases: socketserver.BaseRequestHandler

Handler for MCP-over-TCP connections.

This is a Python handler for Python’s TCPServer, which forwards to the RequestHandler attached to the server.

handle() → None

Handles requests on a socket

receive_request() → Optional[bytes]

Receives a request

Returns

The received bytes

class libmuscle.mcp.tcp_transport_server.TcpTransportServer(handler: libmuscle.mcp.transport_server.RequestHandler, port: int = 0)

Bases: libmuscle.mcp.transport_server.TransportServer

A TransportServer that uses TCP to communicate.

Create a TCPServer.

Parameters

• handler – A RequestHandler to handle requests

• port – The port to use.

Raises

OSError – With errno set to errno.EADDRINUSE if the port is not available.

close() → None

Closes this server.

Stops the server listening, waits for existing clients to disconnect, then frees any other resources.

get_location() → str

Returns the location this server listens on.

Returns

A string containing the location.

class libmuscle.mcp.tcp_transport_server.TcpTransportServerImpl(host_port_tuple: Tuple[str, int], streamhandler: Type, transport_server: libmuscle.mcp.tcp_transport_server.TcpTransportServer)

Bases: socketserver.ThreadingMixIn, socketserver.TCPServer

allow_reuse_address = True

daemon_threads = True