coordinator module¶
The coordinator provides an interface between the process threads, and facilitates inter-process communication. It is a wrapper around xml-rpc, which allowed us to use defined data-structures such as SensorValues
.
Submodules¶
coordinator¶
Classes:
|
|
|
|
|
Functions:
|
- class pvp.coordinator.coordinator.CoordinatorBase(sim_mode=False)[source]¶
Bases:
object
Methods:
get_sensors
()get_alarms
()set_control
(control_setting)get_control
(control_setting_name)set_breath_detection
(breath_detection)get_breath_detection
()start
()is_running
()kill
()stop
()- get_sensors() pvp.common.message.SensorValues [source]¶
- set_control(control_setting: pvp.common.message.ControlSetting)[source]¶
- get_control(control_setting_name: pvp.common.values.ValueName) pvp.common.message.ControlSetting [source]¶
- class pvp.coordinator.coordinator.CoordinatorLocal(sim_mode=False)[source]¶
Bases:
pvp.coordinator.coordinator.CoordinatorBase
- Parameters
sim_mode –
- _is_running¶
.set()
when thread should stop- Type
Methods:
__init__
([sim_mode])- param sim_mode
get_sensors
()get_alarms
()set_control
(control_setting)get_control
(control_setting_name)set_breath_detection
(breath_detection)get_breath_detection
()start
()Start the coordinator.
is_running
()Test whether the whole system is running
stop
()Stop the coordinator.
kill
()- __init__(sim_mode=False)[source]¶
- Parameters
sim_mode –
- _is_running¶
.set()
when thread should stop- Type
- get_sensors() pvp.common.message.SensorValues [source]¶
- set_control(control_setting: pvp.common.message.ControlSetting)[source]¶
- get_control(control_setting_name: pvp.common.values.ValueName) pvp.common.message.ControlSetting [source]¶
- class pvp.coordinator.coordinator.CoordinatorRemote(sim_mode=False)[source]¶
Bases:
pvp.coordinator.coordinator.CoordinatorBase
Methods:
get_sensors
()get_alarms
()set_control
(control_setting)get_control
(control_setting_name)set_breath_detection
(breath_detection)get_breath_detection
()start
()Start the coordinator.
is_running
()Test whether the whole system is running
stop
()Stop the coordinator.
kill
()Stop the coordinator and end the whole program
- get_sensors() pvp.common.message.SensorValues [source]¶
- set_control(control_setting: pvp.common.message.ControlSetting)[source]¶
- get_control(control_setting_name: pvp.common.values.ValueName) pvp.common.message.ControlSetting [source]¶
- pvp.coordinator.coordinator.get_coordinator(single_process=False, sim_mode=False) pvp.coordinator.coordinator.CoordinatorBase [source]¶
ipc¶
Functions:
|
|
|
|
|
|
|
|
process_manager¶
Classes:
|