Skip to content

Class mediapipe::ImmediateInputStreamHandler

ClassList > mediapipe > ImmediateInputStreamHandler

Inherits the following classes: mediapipe::InputStreamHandler

Public Functions

Type Name
ImmediateInputStreamHandler () = delete
ImmediateInputStreamHandler (std::shared_ptr< tool::TagMap > tag_map, CalculatorContextManager * calculator_context_manager, const MediaPipeOptions & options, bool calculator_run_in_parallel)

Protected Attributes

Type Name
absl::Mutex mutex_

Protected Functions

Type Name
std::vector< SyncSet > sync_sets_ ABSL_GUARDED_BY (mutex_)
std::vector< Timestamp > ready_timestamps_ ABSL_GUARDED_BY (mutex_)
void FillInputSet (Timestamp input_timestamp, InputStreamShardSet * input_set) override
NodeReadiness GetNodeReadiness (Timestamp * min_stream_timestamp) override
void PrepareForRun (std::function< void()> headers_ready_callback, std::function< void()> notification_callback, std::function< void(CalculatorContext *)> schedule_callback, std::function< void(absl::Status)> error_callback) override
int SyncSetCount () override

Public Functions Documentation

function ImmediateInputStreamHandler [1/2]

mediapipe::ImmediateInputStreamHandler::ImmediateInputStreamHandler () = delete

function ImmediateInputStreamHandler [2/2]

mediapipe::ImmediateInputStreamHandler::ImmediateInputStreamHandler (
    std::shared_ptr< tool::TagMap > tag_map,
    CalculatorContextManager * calculator_context_manager,
    const MediaPipeOptions & options,
    bool calculator_run_in_parallel
) 

Protected Attributes Documentation

variable mutex_

absl::Mutex mediapipe::ImmediateInputStreamHandler::mutex_;

Protected Functions Documentation

function ABSL_GUARDED_BY [1/2]

std::vector< SyncSet > sync_sets_ mediapipe::ImmediateInputStreamHandler::ABSL_GUARDED_BY (
    mutex_
) 

function ABSL_GUARDED_BY [2/2]

std::vector< Timestamp > ready_timestamps_ mediapipe::ImmediateInputStreamHandler::ABSL_GUARDED_BY (
    mutex_
) 

function FillInputSet

void mediapipe::ImmediateInputStreamHandler::FillInputSet (
    Timestamp input_timestamp,
    InputStreamShardSet * input_set
) override

function GetNodeReadiness

NodeReadiness mediapipe::ImmediateInputStreamHandler::GetNodeReadiness (
    Timestamp * min_stream_timestamp
) override

function PrepareForRun

void mediapipe::ImmediateInputStreamHandler::PrepareForRun (
    std::function< void()> headers_ready_callback,
    std::function< void()> notification_callback,
    std::function< void(CalculatorContext *)> schedule_callback,
    std::function< void(absl::Status)> error_callback
) override

function SyncSetCount

int mediapipe::ImmediateInputStreamHandler::SyncSetCount () override


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