|
pjmsg_mcap_wrapper
|
Classes | |
| struct | CRC32Table |
| struct | DecompressChunkJob |
A job to decompress the chunk starting at chunkStartOffset. The message indices starting directly after the chunk record and ending at messageIndexEndOffset will be used to find specific messages within the chunk. More... | |
| class | Interval |
| class | IntervalTree |
| struct | ReadJobQueue |
| A priority queue of jobs for an indexed MCAP reader to execute. More... | |
| struct | ReadMessageJob |
A job to read a specific message at offset offset from the decompressed chunk stored in chunkReaderIndex. A timestamp is provided to order this job relative to other jobs. More... | |
Typedefs | |
| using | ReadJob = std::variant< ReadMessageJob, DecompressChunkJob > |
| A union of jobs that an indexed MCAP reader executes. | |
Functions | |
| uint32_t | getUint32LE (const std::byte *data) |
| uint32_t | crc32Update (const uint32_t prev, const std::byte *const data, const size_t length) |
| uint32_t | crc32Final (uint32_t crc) |
| std::string | ToHex (uint8_t byte) |
| std::string | ToHex (std::byte byte) |
| std::string | to_string (const std::string &arg) |
| std::string | to_string (std::string_view arg) |
| std::string | to_string (const char *arg) |
| template<typename... T> | |
| std::string | StrCat (T &&... args) |
| uint32_t | KeyValueMapSize (const KeyValueMap &map) |
| const std::string | CompressionString (Compression compression) |
| uint16_t | ParseUint16 (const std::byte *data) |
| uint32_t | ParseUint32 (const std::byte *data) |
| Status | ParseUint32 (const std::byte *data, uint64_t maxSize, uint32_t *output) |
| uint64_t | ParseUint64 (const std::byte *data) |
| Status | ParseUint64 (const std::byte *data, uint64_t maxSize, uint64_t *output) |
| Status | ParseStringView (const std::byte *data, uint64_t maxSize, std::string_view *output) |
| Status | ParseString (const std::byte *data, uint64_t maxSize, std::string *output) |
| Status | ParseByteArray (const std::byte *data, uint64_t maxSize, ByteArray *output) |
| Status | ParseKeyValueMap (const std::byte *data, uint64_t maxSize, KeyValueMap *output) |
| std::string | MagicToHex (const std::byte *data) |
| template<class Scalar , typename Value > | |
| Value | intervalStart (const Interval< Scalar, Value > &i) |
| template<class Scalar , typename Value > | |
| Value | intervalStop (const Interval< Scalar, Value > &i) |
| template<class Scalar , typename Value > | |
| std::ostream & | operator<< (std::ostream &out, const Interval< Scalar, Value > &i) |
| int | LZ4CompressionLevel (CompressionLevel level) |
| int | ZStdCompressionLevel (CompressionLevel level) |
Variables | |
| static constexpr CRC32Table< 0xedb88320, 8 > | CRC32_TABLE |
| static constexpr uint32_t | CRC32_INIT = 0xffffffff |
| constexpr uint64_t | MinHeaderLength |
| constexpr uint64_t | FooterLength |
| template<class > | |
| constexpr bool | always_false_v = false |
| using mcap::internal::ReadJob = typedef std::variant<ReadMessageJob, DecompressChunkJob> |
A union of jobs that an indexed MCAP reader executes.
Definition at line 38 of file read_job_queue.hpp.
|
inline |
Definition at line 59 of file internal.hpp.
|
inline |
|
inline |
Update a streaming CRC32 calculation.
For performance, this implementation processes the data 8 bytes at a time, using the algorithm presented at: https://github.com/komrad36/CRC#option-9-8-byte-tabular
|
inline |
| Value mcap::internal::intervalStart | ( | const Interval< Scalar, Value > & | i | ) |
Definition at line 27 of file intervaltree.hpp.
| Value mcap::internal::intervalStop | ( | const Interval< Scalar, Value > & | i | ) |
Definition at line 32 of file intervaltree.hpp.
|
inline |
Definition at line 51 of file internal.hpp.
| int mcap::internal::LZ4CompressionLevel | ( | CompressionLevel | level | ) |
Definition at line 151 of file writer.inl.
|
inline |
Definition at line 185 of file internal.hpp.
| std::ostream & mcap::internal::operator<< | ( | std::ostream & | out, |
| const Interval< Scalar, Value > & | i | ||
| ) |
Definition at line 37 of file intervaltree.hpp.
|
inline |
Definition at line 131 of file internal.hpp.
|
inline |
Definition at line 149 of file internal.hpp.
|
inline |
Definition at line 118 of file internal.hpp.
|
inline |
Definition at line 104 of file internal.hpp.
|
inline |
Definition at line 71 of file internal.hpp.
|
inline |
Definition at line 75 of file internal.hpp.
|
inline |
Definition at line 80 of file internal.hpp.
|
inline |
Definition at line 89 of file internal.hpp.
|
inline |
Definition at line 95 of file internal.hpp.
|
inline |
Definition at line 45 of file internal.hpp.
|
inline |
Definition at line 41 of file internal.hpp.
|
inline |
Definition at line 35 of file internal.hpp.
|
inline |
Definition at line 38 of file internal.hpp.
|
inline |
Definition at line 31 of file internal.hpp.
|
inline |
Definition at line 25 of file internal.hpp.
| int mcap::internal::ZStdCompressionLevel | ( | CompressionLevel | level | ) |
Definition at line 224 of file writer.inl.
|
inlineconstexpr |
Definition at line 11 of file read_job_queue.hpp.
|
staticconstexpr |
|
staticconstexpr |
|
constexpr |
Definition at line 18 of file internal.hpp.
|
constexpr |
Definition at line 13 of file internal.hpp.