Class mediapipe::CalculatorNode

ClassList > mediapipe > CalculatorNode

Public Types

Type	Name
typedef std::unordered_map< std::string, std::unordered_set< int > >	OutputStreamToSourcesMap

Public Functions

Type	Name
void	ActivateNode ()
bool	Active () const
	CalculatorNode ()
	CalculatorNode (const CalculatorNode &) = delete
void	CheckIfBecameReady ()
void	CleanupAfterRun (const absl::Status & graph_status)
absl::Status	CloseNode (const absl::Status & graph_status, bool graph_run_ended)
bool	Closed () const
const CalculatorContract &	Contract () const
std::string	DebugName () const
void	EndScheduling ()
const std::string &	Executor () const
const CalculatorState &	GetCalculatorState () const
CalculatorContext *	GetDefaultCalculatorContext () const
internal::SchedulerQueue *	GetSchedulerQueue () const
int	Id () const
absl::Status	Initialize (const ValidatedGraphConfig * validated_graph, NodeTypeInfo::NodeRef node_ref, InputStreamManager * input_stream_managers, OutputStreamManager * output_stream_managers, OutputSidePacketImpl * output_side_packets, int * buffer_size_hint, std::shared_ptr< ProfilingContext > profiling_context)
void	InputSidePacketsReady ()
void	InputStreamHeadersReady ()
bool	IsSource () const
void	NodeOpened ()
absl::Status	OpenNode ()
bool	Opened () const
absl::Status	PrepareForRun (const std::map< std::string, Packet > & all_side_packets, const std::map< std::string, Packet > & service_packets, std::function< void()> ready_for_open_callback, std::function< void()> source_node_opened_callback, std::function< void(CalculatorContext *)> schedule_callback, std::function< void(absl::Status)> error_callback, CounterFactory * counter_factory)
bool	Prepared () const
absl::Status	ProcessNode (CalculatorContext * calculator_context)
bool	ReadyForOpen () const
void	SetExecutor (const std::string & executor)
void	SetMaxInputStreamQueueSize (int max_queue_size)
void	SetQueueSizeCallbacks (InputStreamManager::QueueSizeCallback becomes_full_callback, InputStreamManager::QueueSizeCallback becomes_not_full_callback)
void	SetSchedulerQueue (internal::SchedulerQueue * queue)
Timestamp	SourceProcessOrder (const CalculatorContext * cc) const
bool	TryToBeginScheduling ()
CalculatorNode &	operator= (const CalculatorNode &) = delete
int	source_layer () const

Public Types Documentation

typedef OutputStreamToSourcesMap

typedef std::unordered_map<std::string, std::unordered_set<int> > mediapipe::CalculatorNode::OutputStreamToSourcesMap;

---

Public Functions Documentation

function ActivateNode

void mediapipe::CalculatorNode::ActivateNode () 

---

function Active

bool mediapipe::CalculatorNode::Active () const

---

function CalculatorNode [1/2]

mediapipe::CalculatorNode::CalculatorNode () 

---

function CalculatorNode [2/2]

mediapipe::CalculatorNode::CalculatorNode (
    const CalculatorNode &
) = delete

---

function CheckIfBecameReady

void mediapipe::CalculatorNode::CheckIfBecameReady () 

---

function CleanupAfterRun

void mediapipe::CalculatorNode::CleanupAfterRun (
    const absl::Status & graph_status
) 

---

function CloseNode

absl::Status mediapipe::CalculatorNode::CloseNode (
    const absl::Status & graph_status,
    bool graph_run_ended
) 

---

function Closed

bool mediapipe::CalculatorNode::Closed () const

---

function Contract

inline const CalculatorContract & mediapipe::CalculatorNode::Contract () const

---

function DebugName

std::string mediapipe::CalculatorNode::DebugName () const

---

function EndScheduling

void mediapipe::CalculatorNode::EndScheduling () 

---

function Executor

inline const std::string & mediapipe::CalculatorNode::Executor () const

---

function GetCalculatorState

inline const CalculatorState & mediapipe::CalculatorNode::GetCalculatorState () const

---

function GetDefaultCalculatorContext

inline CalculatorContext * mediapipe::CalculatorNode::GetDefaultCalculatorContext () const

---

function GetSchedulerQueue

inline internal::SchedulerQueue * mediapipe::CalculatorNode::GetSchedulerQueue () const

---

function Id

inline int mediapipe::CalculatorNode::Id () const

---

function Initialize

absl::Status mediapipe::CalculatorNode::Initialize (
    const ValidatedGraphConfig * validated_graph,
    NodeTypeInfo::NodeRef node_ref,
    InputStreamManager * input_stream_managers,
    OutputStreamManager * output_stream_managers,
    OutputSidePacketImpl * output_side_packets,
    int * buffer_size_hint,
    std::shared_ptr< ProfilingContext > profiling_context
) 

---

function InputSidePacketsReady

void mediapipe::CalculatorNode::InputSidePacketsReady () 

---

function InputStreamHeadersReady

void mediapipe::CalculatorNode::InputStreamHeadersReady () 

---

function IsSource

inline bool mediapipe::CalculatorNode::IsSource () const

---

function NodeOpened

void mediapipe::CalculatorNode::NodeOpened () 

---

function OpenNode

absl::Status mediapipe::CalculatorNode::OpenNode () 

---

function Opened

bool mediapipe::CalculatorNode::Opened () const

---

function PrepareForRun

absl::Status mediapipe::CalculatorNode::PrepareForRun (
    const std::map< std::string, Packet > & all_side_packets,
    const std::map< std::string, Packet > & service_packets,
    std::function< void()> ready_for_open_callback,
    std::function< void()> source_node_opened_callback,
    std::function< void(CalculatorContext *)> schedule_callback,
    std::function< void(absl::Status)> error_callback,
    CounterFactory * counter_factory
) 

---

function Prepared

bool mediapipe::CalculatorNode::Prepared () const

---

function ProcessNode

absl::Status mediapipe::CalculatorNode::ProcessNode (
    CalculatorContext * calculator_context
) 

---

function ReadyForOpen

bool mediapipe::CalculatorNode::ReadyForOpen () const

---

function SetExecutor

void mediapipe::CalculatorNode::SetExecutor (
    const std::string & executor
) 

---

function SetMaxInputStreamQueueSize

void mediapipe::CalculatorNode::SetMaxInputStreamQueueSize (
    int max_queue_size
) 

---

function SetQueueSizeCallbacks

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

---

function SetSchedulerQueue

inline void mediapipe::CalculatorNode::SetSchedulerQueue (
    internal::SchedulerQueue * queue
) 

---

function SourceProcessOrder

Timestamp mediapipe::CalculatorNode::SourceProcessOrder (
    const CalculatorContext * cc
) const

---

function TryToBeginScheduling

bool mediapipe::CalculatorNode::TryToBeginScheduling () 

---

function operator=

CalculatorNode & mediapipe::CalculatorNode::operator= (
    const CalculatorNode &
) = delete

---

function source_layer

inline int mediapipe::CalculatorNode::source_layer () const

---

---

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