niryo_libraries.rosbag.bag.

class documentation

class _BagReader200(_BagReader):

Support class for reading v2.0 bag files.

Method	`__init__`	Undocumented
Method	`read_chunk_header`	Undocumented
Method	`read_chunk_info_record`	Undocumented
Method	`read_connection_index_record`	Undocumented
Method	`read_connection_record`	Undocumented
Method	`read_file_header_record`	Undocumented
Method	`read_messages`	Undocumented
Method	`reindex`	Generates all bag index information by rereading the chunks. Assumes the file header has been read.
Method	`seek_and_read_message_data_record`	Undocumented
Method	`start_reading`	Undocumented
Instance Variable	`decompressed_chunk`	Undocumented
Instance Variable	`decompressed_chunk_io`	Undocumented
Instance Variable	`decompressed_chunk_pos`	Undocumented
Method	`_advance_to_next_record`	Undocumented
Method	`_read_connection_index_records`	Undocumented
Method	`_read_terminal_connection_records`	Undocumented
Method	`_reindex_read_chunk`	Undocumented

Inherited from _BagReader:

Instance Variable bag Undocumented

def __init__(self, bag): ¶

overrides niryo_libraries.rosbag.bag._BagReader.__init__

Undocumented

def read_chunk_header(self): ¶

Undocumented

def read_chunk_info_record(self): ¶

Undocumented

def read_connection_index_record(self): ¶

Undocumented

def read_connection_record(self, f, encrypt): ¶

Undocumented

def read_file_header_record(self): ¶

Undocumented

def read_messages(self, topics, start_time, end_time, connection_filter, raw, return_connection_header=False): ¶

overrides niryo_libraries.rosbag.bag._BagReader.read_messages

Undocumented

def reindex(self): ¶

overrides niryo_libraries.rosbag.bag._BagReader.reindex

Generates all bag index information by rereading the chunks. Assumes the file header has been read.

def seek_and_read_message_data_record(self, position, raw, return_connection_header=False): ¶

Undocumented

def start_reading(self): ¶

overrides niryo_libraries.rosbag.bag._BagReader.start_reading

Undocumented

decompressed_chunk = ¶

Undocumented

decompressed_chunk_io = ¶

Undocumented

decompressed_chunk_pos = ¶

Undocumented

def _advance_to_next_record(self, op): ¶

Undocumented

def _read_connection_index_records(self): ¶

Undocumented

def _read_terminal_connection_records(self): ¶

Undocumented

def _reindex_read_chunk(self, f, chunk_pos, total_bytes): ¶

Undocumented

niryo_libraries.rosbag.bag._BagReader200