Skip to content

Class mediapipe::OutputStreamManager

ClassList > mediapipe > OutputStreamManager

Public Functions

Type Name
void AddMirror (InputStreamHandler * input_stream_handler, CollectionItemId id)
void Close ()
Timestamp ComputeOutputTimestampBound (const OutputStreamShard & output_stream_shard, Timestamp input_timestamp) const
const Packet & Header () const
absl::Status Initialize (const std::string & name, const PacketType * packet_type)
bool IsClosed () const
void LockIntroData ()
const std::string & Name () const
Timestamp NextTimestampBound () const
TimestampDiff Offset () const
bool OffsetEnabled () const
OutputStreamManager () = default
void PrepareForRun (std::function< void(absl::Status)> error_callback)
void PropagateHeader ()
void PropagateUpdatesToMirrors (Timestamp next_timestamp_bound, OutputStreamShard * output_stream_shard)
void ResetShard (OutputStreamShard * output_stream_shard)
void SetMaxQueueSize (int max_queue_size)
OutputStreamSpec * Spec ()

Public Functions Documentation

function AddMirror

void mediapipe::OutputStreamManager::AddMirror (
    InputStreamHandler * input_stream_handler,
    CollectionItemId id
) 

function Close

void mediapipe::OutputStreamManager::Close () 

function ComputeOutputTimestampBound

Timestamp mediapipe::OutputStreamManager::ComputeOutputTimestampBound (
    const OutputStreamShard & output_stream_shard,
    Timestamp input_timestamp
) const

function Header

inline const Packet & mediapipe::OutputStreamManager::Header () const

function Initialize

absl::Status mediapipe::OutputStreamManager::Initialize (
    const std::string & name,
    const PacketType * packet_type
) 

function IsClosed

bool mediapipe::OutputStreamManager::IsClosed () const

function LockIntroData

inline void mediapipe::OutputStreamManager::LockIntroData () 

function Name

inline const std::string & mediapipe::OutputStreamManager::Name () const

function NextTimestampBound

Timestamp mediapipe::OutputStreamManager::NextTimestampBound () const

function Offset

inline TimestampDiff mediapipe::OutputStreamManager::Offset () const

function OffsetEnabled

inline bool mediapipe::OutputStreamManager::OffsetEnabled () const

function OutputStreamManager

mediapipe::OutputStreamManager::OutputStreamManager () = default

function PrepareForRun

void mediapipe::OutputStreamManager::PrepareForRun (
    std::function< void(absl::Status)> error_callback
) 

function PropagateHeader

void mediapipe::OutputStreamManager::PropagateHeader () 

function PropagateUpdatesToMirrors

void mediapipe::OutputStreamManager::PropagateUpdatesToMirrors (
    Timestamp next_timestamp_bound,
    OutputStreamShard * output_stream_shard
) 

function ResetShard

void mediapipe::OutputStreamManager::ResetShard (
    OutputStreamShard * output_stream_shard
) 

function SetMaxQueueSize

void mediapipe::OutputStreamManager::SetMaxQueueSize (
    int max_queue_size
) 

function Spec

inline OutputStreamSpec * mediapipe::OutputStreamManager::Spec () 


The documentation for this class was generated from the following file /home/friedel/devel/ILLIXR-plugins/hand_tracking/mediapipe/framework/output_stream_manager.h