Class mediapipe::internal::Scheduler

ClassList > mediapipe > internal > Scheduler

Public Functions

Type	Name
void	AddApplicationThreadTask (std::function< void()> task)
void	AddNodeToSourcesQueue (CalculatorNode * node)
void	AddUnopenedSourceNode (CalculatorNode * node)
void	AddedPacketToGraphInputStream ()
void	AssignNodeToSchedulerQueue (CalculatorNode * node)
void	Cancel ()
void	CleanupAfterRun ()
void	CloseAllSourceNodes ()
void	ClosedAllGraphInputStreams ()
void	EmittedObservedOutput ()
internal::SchedulerTimes	GetSchedulerTimes ()
bool	IsPaused ()
bool	IsTerminated ()
void	Pause ()
void	QueueIdleStateChanged (bool idle)
void	Reset ()
void	Resume ()
void	ScheduleNodeForOpen (CalculatorNode * node)
void	ScheduleNodeIfNotThrottled (CalculatorNode * node, CalculatorContext * cc)
void	ScheduleUnthrottledReadyNodes (const std::vector< CalculatorNode * > & nodes_to_schedule)
	Scheduler (const Scheduler &) = delete
	Scheduler (CalculatorGraph * graph)
void	SetExecutor (Executor * executor)
void	SetHasError (bool error)
absl::Status	SetNonDefaultExecutor (const std::string & name, Executor * executor)
void	Start ()
void	ThrottledGraphInputStream ()
void	UnthrottledGraphInputStream ()
absl::Status	WaitForObservedOutput ()
absl::Status	WaitUntilDone ()
void	WaitUntilGraphInputStreamUnthrottled (absl::Mutex * secondary_mutex)
absl::Status	WaitUntilIdle ()
Scheduler &	operator= (const Scheduler &) = delete
	~Scheduler ()

Public Functions Documentation

function AddApplicationThreadTask

void mediapipe::internal::Scheduler::AddApplicationThreadTask (
    std::function< void()> task
) 

---

function AddNodeToSourcesQueue

void mediapipe::internal::Scheduler::AddNodeToSourcesQueue (
    CalculatorNode * node
) 

---

function AddUnopenedSourceNode

void mediapipe::internal::Scheduler::AddUnopenedSourceNode (
    CalculatorNode * node
) 

---

function AddedPacketToGraphInputStream

void mediapipe::internal::Scheduler::AddedPacketToGraphInputStream () 

---

function AssignNodeToSchedulerQueue

void mediapipe::internal::Scheduler::AssignNodeToSchedulerQueue (
    CalculatorNode * node
) 

---

function Cancel

void mediapipe::internal::Scheduler::Cancel () 

---

function CleanupAfterRun

void mediapipe::internal::Scheduler::CleanupAfterRun () 

---

function CloseAllSourceNodes

void mediapipe::internal::Scheduler::CloseAllSourceNodes () 

---

function ClosedAllGraphInputStreams

void mediapipe::internal::Scheduler::ClosedAllGraphInputStreams () 

---

function EmittedObservedOutput

void mediapipe::internal::Scheduler::EmittedObservedOutput () 

---

function GetSchedulerTimes

internal::SchedulerTimes mediapipe::internal::Scheduler::GetSchedulerTimes () 

---

function IsPaused

bool mediapipe::internal::Scheduler::IsPaused () 

---

function IsTerminated

bool mediapipe::internal::Scheduler::IsTerminated () 

---

function Pause

void mediapipe::internal::Scheduler::Pause () 

---

function QueueIdleStateChanged

void mediapipe::internal::Scheduler::QueueIdleStateChanged (
    bool idle
) 

---

function Reset

void mediapipe::internal::Scheduler::Reset () 

---

function Resume

void mediapipe::internal::Scheduler::Resume () 

---

function ScheduleNodeForOpen

void mediapipe::internal::Scheduler::ScheduleNodeForOpen (
    CalculatorNode * node
) 

---

function ScheduleNodeIfNotThrottled

void mediapipe::internal::Scheduler::ScheduleNodeIfNotThrottled (
    CalculatorNode * node,
    CalculatorContext * cc
) 

---

function ScheduleUnthrottledReadyNodes

void mediapipe::internal::Scheduler::ScheduleUnthrottledReadyNodes (
    const std::vector< CalculatorNode * > & nodes_to_schedule
) 

---

function Scheduler [1/2]

mediapipe::internal::Scheduler::Scheduler (
    const Scheduler &
) = delete

---

function Scheduler [2/2]

explicit mediapipe::internal::Scheduler::Scheduler (
    CalculatorGraph * graph
) 

---

function SetExecutor

void mediapipe::internal::Scheduler::SetExecutor (
    Executor * executor
) 

---

function SetHasError

inline void mediapipe::internal::Scheduler::SetHasError (
    bool error
) 

---

function SetNonDefaultExecutor

absl::Status mediapipe::internal::Scheduler::SetNonDefaultExecutor (
    const std::string & name,
    Executor * executor
) 

---

function Start

void mediapipe::internal::Scheduler::Start () 

---

function ThrottledGraphInputStream

void mediapipe::internal::Scheduler::ThrottledGraphInputStream () 

---

function UnthrottledGraphInputStream

void mediapipe::internal::Scheduler::UnthrottledGraphInputStream () 

---

function WaitForObservedOutput

absl::Status mediapipe::internal::Scheduler::WaitForObservedOutput () 

---

function WaitUntilDone

absl::Status mediapipe::internal::Scheduler::WaitUntilDone () 

---

function WaitUntilGraphInputStreamUnthrottled

void mediapipe::internal::Scheduler::WaitUntilGraphInputStreamUnthrottled (
    absl::Mutex * secondary_mutex
) 

---

function WaitUntilIdle

absl::Status mediapipe::internal::Scheduler::WaitUntilIdle () 

---

function operator=

Scheduler & mediapipe::internal::Scheduler::operator= (
    const Scheduler &
) = delete

---

function ~Scheduler

mediapipe::internal::Scheduler::~Scheduler () 

---

---

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