ezmsg.tools.proc

Classes

class EZProcManager(graph_ip, graph_port, buf_dur=3.0)

Bases: object

Manages the subprocess that runs an ezmsg pipeline comprising a single ShMemCircBuff unit connected to a pipeline. The unit must be parameterized with the correct shared memory name. We do not actually interact with the shared memory in this class. See .mirror.EzmsgShmMirror.

Parameters:

• graph_ip (str)

• graph_port (int)

• buf_dur (float)

__init__(graph_ip, graph_port, buf_dur=3.0)

Parameters:

• graph_ip (str)

• graph_port (int)

• buf_dur (float)

Return type:

None

property node_path: str

property conn: Connection | None

reset(node_path)

Parameters:

node_path (str | None)

Return type:

None

cleanup()

class EzMonitorProcess(settings, topic, address=None)

Bases: Process

Parameters:

• settings (ShMemCircBuffSettings)

• topic (str)

• address (Tuple[str, int] | None)

__init__(settings, topic, address=None)

Parameters:

• settings (ShMemCircBuffSettings)

• topic (str)

• address (Tuple[str, int] | None)

Return type:

None

run()

Method to be run in sub-process; can be overridden in sub-class

Return type:

None

class EzMonitorProcess(settings, topic, address=None)

Bases: Process

Parameters:

• settings (ShMemCircBuffSettings)

• topic (str)

• address (Tuple[str, int] | None)

__init__(settings, topic, address=None)

Parameters:

• settings (ShMemCircBuffSettings)

• topic (str)

• address (Tuple[str, int] | None)

Return type:

None

run()

Method to be run in sub-process; can be overridden in sub-class

Return type:

None

class EZProcManager(graph_ip, graph_port, buf_dur=3.0)

Bases: object

Manages the subprocess that runs an ezmsg pipeline comprising a single ShMemCircBuff unit connected to a pipeline. The unit must be parameterized with the correct shared memory name. We do not actually interact with the shared memory in this class. See .mirror.EzmsgShmMirror.

Parameters:

• graph_ip (str)

• graph_port (int)

• buf_dur (float)

__init__(graph_ip, graph_port, buf_dur=3.0)

Parameters:

• graph_ip (str)

• graph_port (int)

• buf_dur (float)

Return type:

None

property node_path: str

property conn: Connection | None

reset(node_path)

Parameters:

node_path (str | None)

Return type:

None

cleanup()