Public Member Functions | |
def | __init__ |
def | add_listener |
def | bag |
def | pause |
def | paused |
def | start |
def | stop |
def | toggle_paused |
def | unpause |
Private Member Functions | |
def | _record |
def | _run_master_check |
Implementation. | |
def | _run_write |
def | _should_subscribe_to |
def | _unsubscribe |
Private Attributes | |
_all | |
_bag | |
_bag_lock | |
_failed_topics | |
_last_update | |
_limit | |
_limited_topics | |
_listeners | |
_master_check_interval | |
_master_check_thread | |
_message_count | |
_paused | |
_regex | |
_regexes | |
_stop_condition | |
_stop_flag | |
_subscriber_helpers | |
_topics | |
_write_queue | |
_write_thread |
Definition at line 53 of file recorder.py.
def rxbag::recorder::Recorder::__init__ | ( | self, | ||
filename, | ||||
bag_lock = None , |
||||
all = True , |
||||
topics = [] , |
||||
regex = False , |
||||
limit = 0 , |
||||
master_check_interval = 1.0 | ||||
) |
Subscribe to ROS messages and record them to a bag file. @param filename: filename of bag to write to @type filename: str @param all: all topics are to be recorded [default: True] @type all: bool @param topics: topics (or regexes if regex is True) to record [default: empty list] @type topics: list of str @param regex: topics should be considered as regular expressions [default: False] @type regex: bool @param limit: record only this number of messages on each topic (if non-positive, then unlimited) [default: 0] @type limit: int @param master_check_interval: period (in seconds) to check master for new topic publications [default: 1] @type master_check_interval: float
Definition at line 54 of file recorder.py.
def rxbag::recorder::Recorder::_record | ( | self, | ||
topic, | ||||
m | ||||
) | [private] |
Definition at line 199 of file recorder.py.
def rxbag::recorder::Recorder::_run_master_check | ( | self | ) | [private] |
Implementation.
Definition at line 136 of file recorder.py.
def rxbag::recorder::Recorder::_run_write | ( | self | ) | [private] |
Definition at line 211 of file recorder.py.
def rxbag::recorder::Recorder::_should_subscribe_to | ( | self, | ||
topic | ||||
) | [private] |
Definition at line 178 of file recorder.py.
def rxbag::recorder::Recorder::_unsubscribe | ( | self, | ||
topic | ||||
) | [private] |
Definition at line 191 of file recorder.py.
def rxbag::recorder::Recorder::add_listener | ( | self, | ||
listener | ||||
) |
Add a listener which gets called whenever a message is recorded. @param listener: function to call @type listener: function taking (topic, message, time)
Definition at line 103 of file recorder.py.
def rxbag::recorder::Recorder::bag | ( | self | ) |
Definition at line 101 of file recorder.py.
def rxbag::recorder::Recorder::pause | ( | self | ) |
Definition at line 120 of file recorder.py.
def rxbag::recorder::Recorder::paused | ( | self | ) |
Definition at line 119 of file recorder.py.
def rxbag::recorder::Recorder::start | ( | self | ) |
Start subscribing and recording messages to bag.
Definition at line 111 of file recorder.py.
def rxbag::recorder::Recorder::stop | ( | self | ) |
Stop recording.
Definition at line 124 of file recorder.py.
def rxbag::recorder::Recorder::toggle_paused | ( | self | ) |
Definition at line 122 of file recorder.py.
def rxbag::recorder::Recorder::unpause | ( | self | ) |
Definition at line 121 of file recorder.py.
rxbag::recorder::Recorder::_all [private] |
Definition at line 71 of file recorder.py.
rxbag::recorder::Recorder::_bag [private] |
Definition at line 77 of file recorder.py.
rxbag::recorder::Recorder::_bag_lock [private] |
Definition at line 78 of file recorder.py.
Definition at line 82 of file recorder.py.
rxbag::recorder::Recorder::_last_update [private] |
Definition at line 83 of file recorder.py.
rxbag::recorder::Recorder::_limit [private] |
Definition at line 74 of file recorder.py.
Definition at line 81 of file recorder.py.
rxbag::recorder::Recorder::_listeners [private] |
Definition at line 79 of file recorder.py.
Definition at line 75 of file recorder.py.
Definition at line 97 of file recorder.py.
Definition at line 95 of file recorder.py.
rxbag::recorder::Recorder::_paused [private] |
Definition at line 85 of file recorder.py.
rxbag::recorder::Recorder::_regex [private] |
Definition at line 73 of file recorder.py.
rxbag::recorder::Recorder::_regexes [private] |
Definition at line 91 of file recorder.py.
Definition at line 86 of file recorder.py.
rxbag::recorder::Recorder::_stop_flag [private] |
Definition at line 87 of file recorder.py.
Definition at line 80 of file recorder.py.
rxbag::recorder::Recorder::_topics [private] |
Definition at line 72 of file recorder.py.
rxbag::recorder::Recorder::_write_queue [private] |
Definition at line 84 of file recorder.py.
rxbag::recorder::Recorder::_write_thread [private] |
Definition at line 98 of file recorder.py.