nvflare.fuel.f3.drivers.socket_conn module

class ConnectionHandler(request, client_address, server)[source]

Bases: BaseRequestHandler

handle()[source]
class SocketConnection(sock: Any, connector: ConnectorInfo, secure: bool = False)[source]

Bases: Connection

close()[source]

Close connection

Raises:

CommError – If any errors

get_conn_properties() → dict[source]

Get connection specific properties, like peer address, TLS certificate etc

Raises:

CommError – If any errors

read_frame() → bytes | bytearray | memoryview | list[source]
read_frame_loop()[source]
read_into(buffer: bytes | bytearray | memoryview | list, offset: int, length: int)[source]
read_loop()[source]
send_frame(frame: bytes | bytearray | memoryview | list)[source]

Send a SFM frame through the connection to the remote endpoint.

Parameters:

frame – The frame to be sent

Raises:

CommError – If any error happens while sending the frame