|
| | canonical (typename, unbounded=False) |
| |
| | create_publisher (topic, cls_or_typename, queue_size) |
| |
| | create_subscriber (topic, typename, handler, queue_size) |
| |
| | deserialize_message (raw, cls_or_typename) |
| |
| | format_message_value (msg, name, value) |
| |
| | generate_message_classes (typename, typedef) |
| |
| | get_message_class (typename) |
| |
| | get_message_definition (msg_or_type) |
| |
| | get_message_fields (val) |
| |
| | get_message_type (msg_or_cls) |
| |
| | get_message_type_hash (msg_or_type) |
| |
| | get_message_value (msg, name, typename=None, default=Ellipsis) |
| |
| | get_rostime (fallback=False) |
| |
| | get_topic_types () |
| |
| | init_node (name) |
| |
| | is_ros_message (val, ignore_time=False) |
| |
| | is_ros_time (val) |
| |
| | make_duration (secs=0, nsecs=0) |
| |
| | make_time (secs=0, nsecs=0) |
| |
| | scalar (typename) |
| |
| | serialize_message (msg) |
| |
| | set_message_value (obj, name, value) |
| |
| | shutdown_node () |
| |
| | to_duration (val) |
| |
| | to_nsec (val) |
| |
| | to_sec (val) |
| |
| | to_sec_nsec (val) |
| |
| | to_time (val) |
| |
| | validate (live=False) |
| |
|
| | Bag = ROS1Bag |
| |
| tuple | BAG_EXTENSIONS = (".bag", ".bag.active") |
| | Bagfile extensions to seek.
|
| |
| | genpy_mtx = threading.RLock() |
| | Mutex for ensuring exclusive access to genpy generator (genpy.dynamic is not thread-safe)
|
| |
| | master = None |
| | rospy.MasterProxy instance
|
| |
| dict | ROS_ALIAS_TYPES = {"byte": "int8", "char": "uint8"} |
| | Mapping between type aliases and real types, like {"byte": "int8"}.
|
| |
| dict | ROS_TIME_CLASSES = {rospy.Time: "time", rospy.Duration: "duration"} |
| | ROS1 time/duration types mapped to type names.
|
| |
| list | ROS_TIME_TYPES = ["time", "duration"] |
| | ROS1 time/duration types.
|
| |
| tuple | SKIP_EXTENSIONS = (".bag.orig.active", ) |
| | Bagfile extensions to skip.
|
| |
| float | SLEEP_INTERVAL = 0.5 |
| | Seconds between checking whether ROS master is available.
|
| |
| dict | TYPECLASSES = {} |
| | {(typename, typehash): message type class}
|
| |
ROS1 interface.
------------------------------------------------------------------------------
This file is part of grepros - grep for ROS bag files and live topics.
Released under the BSD License.
@author Erki Suurjaak
@created 01.11.2021
@modified 13.02.2026
------------------------------------------------------------------------------
| create_subscriber |
( |
|
topic, |
|
|
|
typename, |
|
|
|
handler, |
|
|
|
queue_size |
|
) |
| |
Returns a rospy.Subscriber.
Local message packages are not required. Subscribes as AnyMsg,
creates message class dynamically from connection info,
and deserializes message before providing to handler.
Supplemented with .get_message_class(), .get_message_definition(),
.get_message_type_hash(), and .get_qoses().
The supplementary .get_message_xyz() methods should only be invoked after at least one message
has been received from the topic, as they get populated from live connection metadata.
Definition at line 531 of file ros1.py.
1.9.8