dragon.mpbridge.connection

Dragon’s replacement for the Multiprocessing Connection and Pipe objects

Functions

Client(address[, family, authkey, original, ...])
DragonClient(address[, family, authkey])
Listener([address, family, backlog, ...])
Pipe([duplex, original, use_base_impl])	Generate two Connection objects to be used by only one process each.
activate_monkeypatch_connection_os()
rebuild_connection(df, readable, writable, ...)
reduce_connection(conn)

Classes

BaseImplListener
ConnGlue	Glue around dragon.infrastructure.connection.Connection.
ConnGlueBase
DragonConnection
DragonListener
PseudoOS

class ConnGlue

Glue around dragon.infrastructure.connection.Connection.

__init__(ucid, note, lowerlevel_conn, *args, **kwargs)

class DragonConnection

__init__(handle: ConnGlue, readable=True, writable=True)

fileno()

File descriptor or handle of the connection

Pipe(duplex=True, *, original=None, use_base_impl=True)

Generate two Connection objects to be used by only one process each.

Parameters

duplex (bool) – If True, both ends of the Pipe may send and receive. Optional, defaults to True.

Returns

tuple of connection objects

class DragonListener

__init__(*args, **kwargs)

class BaseImplListener

__init__(*args, **kwargs)