Class mediapipe::InputStreamHandler

ClassList > mediapipe > InputStreamHandler

Inherited by the following classes: mediapipe::DefaultInputStreamHandler, mediapipe::ImmediateInputStreamHandler, mediapipe::internal::GraphOutputStream::GraphOutputStreamHandler

Classes

Type	Name
class	SyncSet

Public Functions

Type	Name
virtual void	AddPackets (CollectionItemId id, const std::list< Packet > & packets)
void	ClearCurrentInputs (CalculatorContext * calculator_context)
void	Close ()
std::string	DebugStreamNames () const
void	FinalizeInputSet (Timestamp timestamp, InputStreamShardSet * input_set)
InputStreamManager *	GetInputStreamManager (CollectionItemId id)
std::vector< std::tuple< std::string, int, int, Timestamp > >	GetMonitoringInfo ()
absl::Status	InitializeInputStreamManagers (InputStreamManager * flat_input_stream_managers)
	InputStreamHandler (std::shared_ptr< tool::TagMap > tag_map, CalculatorContextManager * calculator_context_manager, const MediaPipeOptions & options, bool calculator_run_in_parallel)
const std::shared_ptr< tool::TagMap > &	InputTagMap () const
virtual void	MovePackets (CollectionItemId id, std::list< Packet > * packets)
int	NumInputStreams () const
virtual 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)
bool	ProcessTimestampBounds ()
bool	ScheduleInvocations (int max_allowance, Timestamp * input_bound)
void	SetHeader (CollectionItemId id, const Packet & header)
void	SetMaxQueueSize (int max_queue_size)
void	SetMaxQueueSize (CollectionItemId id, int max_queue_size)
void	SetNextTimestampBound (CollectionItemId id, Timestamp bound)
void	SetProcessTimestampBounds (bool process_ts)
void	SetQueueSizeCallbacks (InputStreamManager::QueueSizeCallback becomes_full_callback, InputStreamManager::QueueSizeCallback becomes_not_full_callback)
absl::Status	SetupInputShards (InputStreamShardSet * input_shards)
virtual int	SyncSetCount ()
int	UnsetHeaderCount () const
void	UpdateInputShardHeaders (InputStreamShardSet * input_shards)
virtual	~InputStreamHandler () = default

Protected Types

Type	Name
typedef internal::Collection< InputStreamManager * >	InputStreamManagerSet

Protected Attributes

Type	Name
CalculatorContextManager *const	calculator_context_manager_
const bool	calculator_run_in_parallel_
std::function< void(absl::Status)>	error_callback_
InputStreamManagerSet	input_stream_managers_
std::function< void()>	notification_
MediaPipeOptions	options_
bool	prepared_context_for_close_
std::function< void(CalculatorContext *)>	schedule_callback_

Protected Functions

Type	Name
void	AddPacketToShard (InputStreamShard * shard, Packet && value, bool is_done)
virtual void	FillInputSet (Timestamp input_timestamp, InputStreamShardSet * input_set) = 0
virtual NodeReadiness	GetNodeReadiness (Timestamp * min_stream_timestamp) = 0
void	SetBatchSize (int batch_size)
void	SetLatePreparation (bool late_preparation)
const MediaPipeOptions &	options () const

Public Functions Documentation

function AddPackets

virtual void mediapipe::InputStreamHandler::AddPackets (
    CollectionItemId id,
    const std::list< Packet > & packets
) 

---

function ClearCurrentInputs

void mediapipe::InputStreamHandler::ClearCurrentInputs (
    CalculatorContext * calculator_context
) 

---

function Close

void mediapipe::InputStreamHandler::Close () 

---

function DebugStreamNames

std::string mediapipe::InputStreamHandler::DebugStreamNames () const

---

function FinalizeInputSet

void mediapipe::InputStreamHandler::FinalizeInputSet (
    Timestamp timestamp,
    InputStreamShardSet * input_set
) 

---

function GetInputStreamManager

InputStreamManager * mediapipe::InputStreamHandler::GetInputStreamManager (
    CollectionItemId id
) 

---

function GetMonitoringInfo

std::vector< std::tuple< std::string, int, int, Timestamp > > mediapipe::InputStreamHandler::GetMonitoringInfo () 

---

function InitializeInputStreamManagers

absl::Status mediapipe::InputStreamHandler::InitializeInputStreamManagers (
    InputStreamManager * flat_input_stream_managers
) 

---

function InputStreamHandler

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

---

function InputTagMap

inline const std::shared_ptr< tool::TagMap > & mediapipe::InputStreamHandler::InputTagMap () const

---

function MovePackets

virtual void mediapipe::InputStreamHandler::MovePackets (
    CollectionItemId id,
    std::list< Packet > * packets
) 

---

function NumInputStreams

inline int mediapipe::InputStreamHandler::NumInputStreams () const

---

function PrepareForRun

virtual void mediapipe::InputStreamHandler::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
) 

---

function ProcessTimestampBounds

inline bool mediapipe::InputStreamHandler::ProcessTimestampBounds () 

---

function ScheduleInvocations

bool mediapipe::InputStreamHandler::ScheduleInvocations (
    int max_allowance,
    Timestamp * input_bound
) 

---

function SetHeader

void mediapipe::InputStreamHandler::SetHeader (
    CollectionItemId id,
    const Packet & header
) 

---

function SetMaxQueueSize [1/2]

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

---

function SetMaxQueueSize [2/2]

void mediapipe::InputStreamHandler::SetMaxQueueSize (
    CollectionItemId id,
    int max_queue_size
) 

---

function SetNextTimestampBound

void mediapipe::InputStreamHandler::SetNextTimestampBound (
    CollectionItemId id,
    Timestamp bound
) 

---

function SetProcessTimestampBounds

inline void mediapipe::InputStreamHandler::SetProcessTimestampBounds (
    bool process_ts
) 

---

function SetQueueSizeCallbacks

void mediapipe::InputStreamHandler::SetQueueSizeCallbacks (
    InputStreamManager::QueueSizeCallback becomes_full_callback,
    InputStreamManager::QueueSizeCallback becomes_not_full_callback
) 

---

function SetupInputShards

absl::Status mediapipe::InputStreamHandler::SetupInputShards (
    InputStreamShardSet * input_shards
) 

---

function SyncSetCount

inline virtual int mediapipe::InputStreamHandler::SyncSetCount () 

---

function UnsetHeaderCount

inline int mediapipe::InputStreamHandler::UnsetHeaderCount () const

---

function UpdateInputShardHeaders

void mediapipe::InputStreamHandler::UpdateInputShardHeaders (
    InputStreamShardSet * input_shards
) 

---

function ~InputStreamHandler

virtual mediapipe::InputStreamHandler::~InputStreamHandler () = default

---

Protected Types Documentation

typedef InputStreamManagerSet

typedef internal::Collection<InputStreamManager*> mediapipe::InputStreamHandler::InputStreamManagerSet;

---

Protected Attributes Documentation

variable calculator_context_manager_

CalculatorContextManager* const mediapipe::InputStreamHandler::calculator_context_manager_;

---

variable calculator_run_in_parallel_

const bool mediapipe::InputStreamHandler::calculator_run_in_parallel_;

---

variable error_callback_

std::function<void(absl::Status)> mediapipe::InputStreamHandler::error_callback_;

---

variable input_stream_managers_

InputStreamManagerSet mediapipe::InputStreamHandler::input_stream_managers_;

---

variable notification_

std::function<void()> mediapipe::InputStreamHandler::notification_;

---

variable options_

MediaPipeOptions mediapipe::InputStreamHandler::options_;

---

variable prepared_context_for_close_

bool mediapipe::InputStreamHandler::prepared_context_for_close_;

---

variable schedule_callback_

std::function<void(CalculatorContext*)> mediapipe::InputStreamHandler::schedule_callback_;

---

Protected Functions Documentation

function AddPacketToShard

inline void mediapipe::InputStreamHandler::AddPacketToShard (
    InputStreamShard * shard,
    Packet && value,
    bool is_done
) 

---

function FillInputSet

virtual void mediapipe::InputStreamHandler::FillInputSet (
    Timestamp input_timestamp,
    InputStreamShardSet * input_set
) = 0

---

function GetNodeReadiness

virtual NodeReadiness mediapipe::InputStreamHandler::GetNodeReadiness (
    Timestamp * min_stream_timestamp
) = 0

---

function SetBatchSize

void mediapipe::InputStreamHandler::SetBatchSize (
    int batch_size
) 

---

function SetLatePreparation

void mediapipe::InputStreamHandler::SetLatePreparation (
    bool late_preparation
) 

---

function options

inline const MediaPipeOptions & mediapipe::InputStreamHandler::options () const

---

---

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