libmuscle.mcp.tcp_util module

exception libmuscle.mcp.tcp_util.SocketClosed

Bases: Exception

Raised when trying to read from a socket that was closed.

libmuscle.mcp.tcp_util.recv_all(socket: socket, length: int) → bytes

Receive length bytes from a socket.

Parameters:

• socket – Socket to receive on.

• length – Number of bytes to receive.

Raises:

• SocketClosed – If the socket was closed by the peer.

• RuntimeError – If a read error occurred.

libmuscle.mcp.tcp_util.recv_int64(socket: socket) → int

Receives an int as a 64-bit signed little endian number.

Parameters:

socket – The socket to receive on.

Raises:

• SocketClosed – If the socket was closed by the peer.

• RuntimeError – If a read error occurred.

libmuscle.mcp.tcp_util.send_int64(socket: socket, data: int) → None

Sends an int as a 64-bit signed little endian number.

Parameters:

• socket – The socket to send on.

• data – The number to send.

Raises:

RuntimeError – If there was an error sending the data.