module documentation

Local process implementation for running and monitoring nodes.

Class LocalProcess Process launched on local machine
Function create_master_process Launch a master @param type_: name of master executable (currently just Master.ZENMASTER) @type type_: str @param ros_root: ROS_ROOT environment setting @type ros_root: str @param port: port to launch master on @type port: int @param num_workers: number of worker threads...
Function create_node_process Factory for generating processes for launching local ROS nodes. Also registers the process with the L{ProcessMonitor} so that events can be generated when the process dies.
Constant DEFAULT_TIMEOUT_SIGINT Undocumented
Constant DEFAULT_TIMEOUT_SIGTERM Undocumented
Function _cleanup_remappings Remove all instances of args that start with prefix. This is used to remove args that were previously added (and are now being regenerated due to respawning)
Function _next_counter Undocumented
Variable _counter Undocumented
Variable _logger Undocumented
def create_master_process(run_id, type_, ros_root, port, num_workers=NUM_WORKERS, timeout=None, master_logger_level=False, sigint_timeout=DEFAULT_TIMEOUT_SIGINT, sigterm_timeout=DEFAULT_TIMEOUT_SIGTERM):

Launch a master @param type_: name of master executable (currently just Master.ZENMASTER) @type type_: str @param ros_root: ROS_ROOT environment setting @type ros_root: str @param port: port to launch master on @type port: int @param num_workers: number of worker threads. @type num_workers: int @param timeout: socket timeout for connections. @type timeout: float @param master_logger_level: rosmaster.master logger debug level @type master_logger_level=: str or False @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 @raise RLException: if type_ or port is invalid or sigint_timeout or sigterm_timeout are nonpositive.

def create_node_process(run_id, node, master_uri, sigint_timeout=DEFAULT_TIMEOUT_SIGINT, sigterm_timeout=DEFAULT_TIMEOUT_SIGTERM):

Factory for generating processes for launching local ROS nodes. Also registers the process with the L{ProcessMonitor} so that events can be generated when the process dies.

@param run_id: run_id of launch @type run_id: str @param node: node to launch. Node name must be assigned. @type node: L{Node} @param master_uri: API URI for master node @type master_uri: str @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 @return: local process instance @rtype: L{LocalProcess} @raise NodeParamsException: If the node's parameters are improperly specific @raise RLException: If sigint_timeout or sigterm_timeout are nonpositive.

DEFAULT_TIMEOUT_SIGINT: float =

Undocumented

Value
15.0
DEFAULT_TIMEOUT_SIGTERM: float =

Undocumented

Value
2.0
def _cleanup_remappings(args, prefix):

Remove all instances of args that start with prefix. This is used to remove args that were previously added (and are now being regenerated due to respawning)

def _next_counter():

Undocumented

_counter: int =

Undocumented

_logger =

Undocumented