niryo_libraries.roslaunch.remote.ROSRemoteRunner

class documentation

class ROSRemoteRunner(roslaunch.launch.ROSRemoteRunnerIF):

Constructor: ROSRemoteRunner(run_id, rosconfig, pm, server, ...)

View In Hierarchy

Manages the running of remote roslaunch children

Method __init__ :param pm process monitor, ProcessMonitor :param server: roslaunch parent server, ROSLaunchParentNode :param sigint_timeout: The SIGINT timeout used when killing nodes (in seconds). :type sigint_timeout: float :param sigterm_timeout: The SIGTERM timeout used when killing nodes if SIGINT does not stop the node (in seconds)...
Method add_process_listener Listen to events about remote processes dying. Not threadsafe. Must be called before processes started.
Method launch_remote_nodes Contact each child to launch remote nodes
Method start_children Start the child roslaunch processes
Instance Variable listeners Undocumented
Instance Variable logger Undocumented
Instance Variable machine_list Undocumented
Instance Variable pm Undocumented
Instance Variable remote_nodes Undocumented
Instance Variable remote_processes Undocumented
Instance Variable rosconfig Undocumented
Instance Variable run_id Undocumented
Instance Variable server Undocumented
Instance Variable sigint_timeout Undocumented
Instance Variable sigterm_timeout Undocumented
Method _assume_failed Utility routine for logging/recording nodes that failed
Method _start_child Undocumented
def __init__(self, run_id, rosconfig, pm, server, sigint_timeout=DEFAULT_TIMEOUT_SIGINT, sigterm_timeout=DEFAULT_TIMEOUT_SIGTERM):

:param pm process monitor, ProcessMonitor :param server: roslaunch parent server, ROSLaunchParentNode :param sigint_timeout: The SIGINT timeout used when killing nodes (in seconds). :type sigint_timeout: float :param sigterm_timeout: The SIGTERM timeout used when killing nodes if SIGINT does not stop the node (in seconds). :type sigterm_timeout: float

Parameters
run_idroslaunch run_id of this runner, str
rosconfigUndocumented
pmUndocumented
serverUndocumented
sigint_timeoutUndocumented
sigterm_timeoutUndocumented
configlaunch configuration, ROSConfig
def add_process_listener(self, l):

Listen to events about remote processes dying. Not threadsafe. Must be called before processes started.

Parameters
lProcessListener
def launch_remote_nodes(self):

Contact each child to launch remote nodes

def start_children(self):

Start the child roslaunch processes

listeners: list =

Undocumented

logger =

Undocumented

machine_list =

Undocumented

pm =

Undocumented

remote_nodes: dict =

Undocumented

remote_processes =

Undocumented

rosconfig =

Undocumented

run_id =

Undocumented

server =

Undocumented

sigint_timeout =

Undocumented

sigterm_timeout =

Undocumented

def _assume_failed(self, nodes, failed):

Utility routine for logging/recording nodes that failed

Parameters
nodeslist of nodes that are assumed to have failed, Node
failedlist of names of nodes that have failed to extend, [str]
def _start_child(self, server_node_uri, machine, counter):

Undocumented