Class mediapipe::CalculatorGraph

ClassList > mediapipe > CalculatorGraph

Public Types

Type	Name
enum	GraphInputStreamAddMode

Public Functions

Type	Name
	ABSL_DEPRECATED ("CalculatorGraph will not allow external callers to explictly pause and " "resume a graph.")
	ABSL_DEPRECATED ("CalculatorGraph will not allow external callers to explictly pause and " "resume a graph.")
StatusOrPoller	AddOutputStreamPoller (const std::string & stream_name, bool observe_timestamp_bounds=false)
absl::Status	AddPacketToInputStream (absl::string_view stream_name, const Packet & packet)
absl::Status	AddPacketToInputStream (absl::string_view stream_name, Packet && packet)
	CalculatorGraph ()
	CalculatorGraph (const CalculatorGraph &) = delete
	CalculatorGraph (CalculatorGraphConfig config)
void	Cancel ()
absl::Status	CloseAllInputStreams ()
absl::Status	CloseAllPacketSources ()
absl::Status	CloseInputStream (const std::string & stream_name)
const CalculatorGraphConfig &	Config () const
absl::Status	DisallowServiceDefaultInitialization ()
bool	GetCombinedErrors (const std::string & error_prefix, absl::Status * error_status)
bool	GetCombinedErrors (absl::Status * error_status)
CounterFactory *	GetCounterFactory ()
std::shared_ptr< GpuResources >	GetGpuResources () const
GraphInputStreamAddMode	GetGraphInputStreamAddMode () const
int	GetMaxInputStreamQueueSize ()
absl::StatusOr< Packet >	GetOutputSidePacket (const std::string & packet_name)
internal::SchedulerTimes	GetSchedulerTimes ()
std::shared_ptr< T >	GetServiceObject (const GraphService< T > & service)
bool	GraphInputStreamsClosed ()
bool	HasError () const
bool	HasInputStream (const std::string & name)
absl::Status	Initialize (CalculatorGraphConfig config, const std::map< std::string, Packet > & side_packets)
absl::Status	Initialize (CalculatorGraphConfig config)
absl::Status	Initialize (const std::vector< CalculatorGraphConfig > & configs, const std::vector< CalculatorGraphTemplate > & templates, const std::map< std::string, Packet > & side_packets={}, const std::string & graph_type="", const Subgraph::SubgraphOptions * options=nullptr)
bool	IsNodeThrottled (int node_id)
absl::Status	ObserveOutputStream (const std::string & stream_name, std::function< absl::Status(const Packet &)> packet_callback, bool observe_timestamp_bounds=false)
void	RecordError (const absl::Status & error)
virtual absl::Status	Run (const std::map< std::string, Packet > & extra_side_packets)
absl::Status	Run ()
ABSL_DEPRECATED("Use profiler()->GetCalculatorProfiles() instead") absl void	SetCounterFactory (CounterFactory * factory)
absl::Status	SetErrorCallback (std::function< void(const absl::Status &)> error_callback)
absl::Status	SetExecutor (const std::string & name, std::shared_ptr< Executor > executor)
absl::Status	SetGpuResources (std::shared_ptr< GpuResources > resources)
void	SetGraphInputStreamAddMode (GraphInputStreamAddMode mode)
absl::Status	SetInputStreamMaxQueueSize (const std::string & stream_name, int max_queue_size)
absl::Status	SetInputStreamTimestampBound (const std::string & stream_name, Timestamp timestamp)
absl::Status	SetServiceObject (const GraphService< T > & service, std::shared_ptr< T > object)
absl::Status	SetServicePacket (const GraphServiceBase & service, Packet p)
absl::Status	StartRun (const std::map< std::string, Packet > & extra_side_packets)
absl::Status	StartRun (const std::map< std::string, Packet > & extra_side_packets, const std::map< std::string, Packet > & stream_headers)
bool	UnthrottleSources ()
absl::Status	WaitForObservedOutput ()
absl::Status	WaitUntilDone ()
absl::Status	WaitUntilIdle ()
CalculatorGraph &	operator= (const CalculatorGraph &) = delete
ABSL_DEPRECATED("Prefer using a Calculator to get information of all sorts out of the " "graph.") const OutputStreamManager *FindOutputStreamManager(const std ProfilingContext *	profiler ()
virtual	~CalculatorGraph ()

Public Types Documentation

enum GraphInputStreamAddMode

enum mediapipe::CalculatorGraph::GraphInputStreamAddMode {
    WAIT_TILL_NOT_FULL,
    ADD_IF_NOT_FULL
};

---

Public Functions Documentation

function ABSL_DEPRECATED [1/2]

mediapipe::CalculatorGraph::ABSL_DEPRECATED (
    "CalculatorGraph will not allow external callers to explictly pause and " "resume a graph."
) 

---

function ABSL_DEPRECATED [2/2]

mediapipe::CalculatorGraph::ABSL_DEPRECATED (
    "CalculatorGraph will not allow external callers to explictly pause and " "resume a graph."
) 

---

function AddOutputStreamPoller

StatusOrPoller mediapipe::CalculatorGraph::AddOutputStreamPoller (
    const std::string & stream_name,
    bool observe_timestamp_bounds=false
) 

---

function AddPacketToInputStream [1/2]

absl::Status mediapipe::CalculatorGraph::AddPacketToInputStream (
    absl::string_view stream_name,
    const Packet & packet
) 

---

function AddPacketToInputStream [2/2]

absl::Status mediapipe::CalculatorGraph::AddPacketToInputStream (
    absl::string_view stream_name,
    Packet && packet
) 

---

function CalculatorGraph [1/3]

mediapipe::CalculatorGraph::CalculatorGraph () 

---

function CalculatorGraph [2/3]

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

---

function CalculatorGraph [3/3]

explicit mediapipe::CalculatorGraph::CalculatorGraph (
    CalculatorGraphConfig config
) 

---

function Cancel

void mediapipe::CalculatorGraph::Cancel () 

---

function CloseAllInputStreams

absl::Status mediapipe::CalculatorGraph::CloseAllInputStreams () 

---

function CloseAllPacketSources

absl::Status mediapipe::CalculatorGraph::CloseAllPacketSources () 

---

function CloseInputStream

absl::Status mediapipe::CalculatorGraph::CloseInputStream (
    const std::string & stream_name
) 

---

function Config

inline const CalculatorGraphConfig & mediapipe::CalculatorGraph::Config () const

---

function DisallowServiceDefaultInitialization

inline absl::Status mediapipe::CalculatorGraph::DisallowServiceDefaultInitialization () 

---

function GetCombinedErrors [1/2]

bool mediapipe::CalculatorGraph::GetCombinedErrors (
    const std::string & error_prefix,
    absl::Status * error_status
) 

---

function GetCombinedErrors [2/2]

bool mediapipe::CalculatorGraph::GetCombinedErrors (
    absl::Status * error_status
) 

---

function GetCounterFactory

inline CounterFactory * mediapipe::CalculatorGraph::GetCounterFactory () 

---

function GetGpuResources

std::shared_ptr< GpuResources > mediapipe::CalculatorGraph::GetGpuResources () const

---

function GetGraphInputStreamAddMode

GraphInputStreamAddMode mediapipe::CalculatorGraph::GetGraphInputStreamAddMode () const

---

function GetMaxInputStreamQueueSize

int mediapipe::CalculatorGraph::GetMaxInputStreamQueueSize () 

---

function GetOutputSidePacket

absl::StatusOr< Packet > mediapipe::CalculatorGraph::GetOutputSidePacket (
    const std::string & packet_name
) 

---

function GetSchedulerTimes

inline internal::SchedulerTimes mediapipe::CalculatorGraph::GetSchedulerTimes () 

---

function GetServiceObject

template<typename T>
inline std::shared_ptr< T > mediapipe::CalculatorGraph::GetServiceObject (
    const GraphService< T > & service
) 

---

function GraphInputStreamsClosed

inline bool mediapipe::CalculatorGraph::GraphInputStreamsClosed () 

---

function HasError

inline bool mediapipe::CalculatorGraph::HasError () const

---

function HasInputStream

bool mediapipe::CalculatorGraph::HasInputStream (
    const std::string & name
) 

---

function Initialize [1/4]

absl::Status mediapipe::CalculatorGraph::Initialize (
    CalculatorGraphConfig config,
    const std::map< std::string, Packet > & side_packets
) 

---

function Initialize [2/4]

absl::Status mediapipe::CalculatorGraph::Initialize (
    CalculatorGraphConfig config
) 

---

function Initialize [3/4]

absl::Status mediapipe::CalculatorGraph::Initialize (
    const std::vector< CalculatorGraphConfig > & configs,
    const std::vector< CalculatorGraphTemplate > & templates,
    const std::map< std::string, Packet > & side_packets={},
    const std::string & graph_type="",
    const Subgraph::SubgraphOptions * options=nullptr
) 

---

function IsNodeThrottled

bool mediapipe::CalculatorGraph::IsNodeThrottled (
    int node_id
) 

---

function ObserveOutputStream

absl::Status mediapipe::CalculatorGraph::ObserveOutputStream (
    const std::string & stream_name,
    std::function< absl::Status(const Packet &)> packet_callback,
    bool observe_timestamp_bounds=false
) 

---

function RecordError

void mediapipe::CalculatorGraph::RecordError (
    const absl::Status & error
) 

---

function Run [1/2]

virtual absl::Status mediapipe::CalculatorGraph::Run (
    const std::map< std::string, Packet > & extra_side_packets
) 

---

function Run [2/2]

inline absl::Status mediapipe::CalculatorGraph::Run () 

---

function SetCounterFactory

inline ABSL_DEPRECATED("Use profiler()->GetCalculatorProfiles() instead") absl void mediapipe::CalculatorGraph::SetCounterFactory (
    CounterFactory * factory
) 

---

function SetErrorCallback

absl::Status mediapipe::CalculatorGraph::SetErrorCallback (
    std::function< void(const absl::Status &)> error_callback
) 

---

function SetExecutor

absl::Status mediapipe::CalculatorGraph::SetExecutor (
    const std::string & name,
    std::shared_ptr< Executor > executor
) 

---

function SetGpuResources

absl::Status mediapipe::CalculatorGraph::SetGpuResources (
    std::shared_ptr< GpuResources > resources
) 

---

function SetGraphInputStreamAddMode

void mediapipe::CalculatorGraph::SetGraphInputStreamAddMode (
    GraphInputStreamAddMode mode
) 

---

function SetInputStreamMaxQueueSize

absl::Status mediapipe::CalculatorGraph::SetInputStreamMaxQueueSize (
    const std::string & stream_name,
    int max_queue_size
) 

---

function SetInputStreamTimestampBound

absl::Status mediapipe::CalculatorGraph::SetInputStreamTimestampBound (
    const std::string & stream_name,
    Timestamp timestamp
) 

---

function SetServiceObject

template<typename T>
inline absl::Status mediapipe::CalculatorGraph::SetServiceObject (
    const GraphService< T > & service,
    std::shared_ptr< T > object
) 

---

function SetServicePacket

inline absl::Status mediapipe::CalculatorGraph::SetServicePacket (
    const GraphServiceBase & service,
    Packet p
) 

---

function StartRun [1/2]

inline absl::Status mediapipe::CalculatorGraph::StartRun (
    const std::map< std::string, Packet > & extra_side_packets
) 

---

function StartRun [2/2]

absl::Status mediapipe::CalculatorGraph::StartRun (
    const std::map< std::string, Packet > & extra_side_packets,
    const std::map< std::string, Packet > & stream_headers
) 

---

function UnthrottleSources

bool mediapipe::CalculatorGraph::UnthrottleSources () 

---

function WaitForObservedOutput

absl::Status mediapipe::CalculatorGraph::WaitForObservedOutput () 

---

function WaitUntilDone

absl::Status mediapipe::CalculatorGraph::WaitUntilDone () 

---

function WaitUntilIdle

absl::Status mediapipe::CalculatorGraph::WaitUntilIdle () 

---

function operator=

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

---

function profiler

inline ABSL_DEPRECATED("Prefer using a Calculator to get information of all sorts out of the " "graph.") const OutputStreamManager *FindOutputStreamManager(const std ProfilingContext * mediapipe::CalculatorGraph::profiler () 

---

function ~CalculatorGraph

virtual mediapipe::CalculatorGraph::~CalculatorGraph () 

---

---

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