coordinator module

Submodules

coordinator

Classes

CoordinatorBase([sim_mode])
CoordinatorLocal([sim_mode])	param sim_mode
CoordinatorRemote([sim_mode])

Functions

get_coordinator([single_process, sim_mode])

class vent.coordinator.coordinator.CoordinatorBase(sim_mode=False)

Bases: object

Methods

get_control(control_setting_name)
get_sensors()
is_running()
set_control(control_setting)
start()
stop()

get_sensors() → vent.common.message.SensorValues

set_control(control_setting: vent.common.message.ControlSetting)

get_control(control_setting_name: vent.common.values.ValueName) → vent.common.message.ControlSetting

start()

is_running() → bool

stop()

class vent.coordinator.coordinator.CoordinatorLocal(sim_mode=False)

Bases: vent.coordinator.coordinator.CoordinatorBase

Parameters

sim_mode –

Methods

__init__([sim_mode])	param sim_mode
get_control(control_setting_name)
get_sensors()
is_running()	Test whether the whole system is running
set_control(control_setting)
start()	Start the coordinator.
stop()	Stop the coordinator.

_is_running

.set() when thread should stop

Type

threading.Event

__init__(sim_mode=False)

Parameters

sim_mode –

_is_running

.set() when thread should stop

Type

threading.Event

get_sensors() → vent.common.message.SensorValues

set_control(control_setting: vent.common.message.ControlSetting)

get_control(control_setting_name: vent.common.values.ValueName) → vent.common.message.ControlSetting

start()

Start the coordinator. This does a soft start (not allocating a process).

is_running() → bool

Test whether the whole system is running

stop()

Stop the coordinator. This does a soft stop (not kill a process)

class vent.coordinator.coordinator.CoordinatorRemote(sim_mode=False)

Bases: vent.coordinator.coordinator.CoordinatorBase

Methods

get_control(control_setting_name)
get_sensors()
is_running()	Test whether the whole system is running
set_control(control_setting)
start()	Start the coordinator.
stop()	Stop the coordinator.

get_sensors() → vent.common.message.SensorValues

set_control(control_setting: vent.common.message.ControlSetting)

get_control(control_setting_name: vent.common.values.ValueName) → vent.common.message.ControlSetting

start()

Start the coordinator. This does a soft start (not allocating a process).

is_running() → bool

Test whether the whole system is running

stop()

Stop the coordinator. This does a soft stop (not kill a process)

vent.coordinator.coordinator.get_coordinator(single_process=False, sim_mode=False) → vent.coordinator.coordinator.CoordinatorBase

ipc

process_manager

Classes

ProcessManager(sim_mode[, startCommandLine, …])

class vent.coordinator.process_manager.ProcessManager(sim_mode, startCommandLine=None, maxHeartbeatInterval=None)

Bases: object

Methods

heartbeat(timestamp)
restart_process()
start_process()
try_stop_process()

start_process()

try_stop_process()

restart_process()

heartbeat(timestamp)