mcap::internal::ReadJobQueue Struct Reference

Detailed Description

A priority queue of jobs for an indexed MCAP reader to execute.

Definition at line 43 of file read_job_queue.hpp.

#include <read_job_queue.hpp>

Public Member Functions
	ReadJobQueue (bool reverse)
void	push (DecompressChunkJob &&decompressChunkJob)
void	push (ReadMessageJob &&readMessageJob)
ReadJob	pop ()
size_t	len () const

Static Private Member Functions
static Timestamp	TimeComparisonKey (const ReadJob &job, bool reverse)
	return the timestamp key that should be used to compare jobs.
static RecordOffset	PositionComparisonKey (const ReadJob &job, bool reverse)
static bool	CompareForward (const ReadJob &a, const ReadJob &b)
static bool	CompareReverse (const ReadJob &a, const ReadJob &b)

Private Attributes
bool	reverse_ = false
std::vector< ReadJob >	heap_

Constructor & Destructor Documentation

ReadJobQueue()

mcap::internal::ReadJobQueue::ReadJobQueue ( bool  reverse )

inlineexplicit

Definition at line 111 of file read_job_queue.hpp.

Member Function Documentation

CompareForward()

static bool mcap::internal::ReadJobQueue::CompareForward ( const ReadJob &  a, const ReadJob &  b  )

inlinestaticprivate

Definition at line 92 of file read_job_queue.hpp.

CompareReverse()

static bool mcap::internal::ReadJobQueue::CompareReverse ( const ReadJob &  a, const ReadJob &  b  )

inlinestaticprivate

Definition at line 101 of file read_job_queue.hpp.

len()

size_t mcap::internal::ReadJobQueue::len ( ) const

inline

Definition at line 142 of file read_job_queue.hpp.

pop()

ReadJob mcap::internal::ReadJobQueue::pop ( )

inline

Definition at line 131 of file read_job_queue.hpp.

PositionComparisonKey()

static RecordOffset mcap::internal::ReadJobQueue::PositionComparisonKey ( const ReadJob &  job, bool  reverse  )

inlinestaticprivate

Definition at line 71 of file read_job_queue.hpp.

push() [1/2]

void mcap::internal::ReadJobQueue::push ( DecompressChunkJob &&  decompressChunkJob )

inline

Definition at line 113 of file read_job_queue.hpp.

push() [2/2]

void mcap::internal::ReadJobQueue::push ( ReadMessageJob &&  readMessageJob )

inline

Definition at line 122 of file read_job_queue.hpp.

TimeComparisonKey()

static Timestamp mcap::internal::ReadJobQueue::TimeComparisonKey ( const ReadJob &  job, bool  reverse  )

inlinestaticprivate

return the timestamp key that should be used to compare jobs.

Definition at line 51 of file read_job_queue.hpp.

Member Data Documentation

heap_

std::vector<ReadJob> mcap::internal::ReadJobQueue::heap_

private

Definition at line 46 of file read_job_queue.hpp.

reverse_

bool mcap::internal::ReadJobQueue::reverse_ = false

private

Definition at line 45 of file read_job_queue.hpp.

---

The documentation for this struct was generated from the following file:

• read_job_queue.hpp