Class mediapipe::InputStreamManager

ClassList > mediapipe > InputStreamManager

Public Types

Type	Name
typedef std::function< void(InputStreamManager *, bool *)>	QueueSizeCallback

Public Functions

Type	Name
absl::Status	AddPackets (const std::list< Packet > & container, bool * notify)
bool	BackEdge () const
void	Close ()
void	DisableTimestamps ()
void	ErasePacketsEarlierThan (Timestamp timestamp)
Timestamp	GetMinTimestampAmongNLatest (int n) const
const Packet &	Header () const
absl::Status	Initialize (const std::string & name, const PacketType * packet_type, bool back_edge)
	InputStreamManager (const InputStreamManager &) = delete
	InputStreamManager () = default
bool	IsEmpty () const
bool	IsFull () const
int	MaxQueueSize () const
Timestamp	MinTimestampOrBound (bool * is_empty) const
absl::Status	MovePackets (std::list< Packet > * container, bool * notify)
const std::string &	Name () const
int	NumPacketsAdded () const
Packet	PopPacketAtTimestamp (Timestamp timestamp, int * num_packets_dropped, bool * stream_is_done)
Packet	PopQueueHead (bool * stream_is_done)
void	PrepareForRun ()
Packet	QueueHead () const
int	QueueSize () const
absl::Status	SetHeader (const Packet & header)
void	SetMaxQueueSize (int max_queue_size)
absl::Status	SetNextTimestampBound (Timestamp bound, bool * notify)
void	SetQueueSizeCallbacks (QueueSizeCallback becomes_full_callback, QueueSizeCallback becomes_not_full_callback)
InputStreamManager &	operator= (const InputStreamManager &) = delete

Public Types Documentation

typedef QueueSizeCallback

typedef std::function<void(InputStreamManager*, bool*)> mediapipe::InputStreamManager::QueueSizeCallback;

---

Public Functions Documentation

function AddPackets

absl::Status mediapipe::InputStreamManager::AddPackets (
    const std::list< Packet > & container,
    bool * notify
) 

---

function BackEdge

inline bool mediapipe::InputStreamManager::BackEdge () const

---

function Close

void mediapipe::InputStreamManager::Close () 

---

function DisableTimestamps

void mediapipe::InputStreamManager::DisableTimestamps () 

---

function ErasePacketsEarlierThan

void mediapipe::InputStreamManager::ErasePacketsEarlierThan (
    Timestamp timestamp
) 

---

function GetMinTimestampAmongNLatest

Timestamp mediapipe::InputStreamManager::GetMinTimestampAmongNLatest (
    int n
) const

---

function Header

inline const Packet & mediapipe::InputStreamManager::Header () const

---

function Initialize

absl::Status mediapipe::InputStreamManager::Initialize (
    const std::string & name,
    const PacketType * packet_type,
    bool back_edge
) 

---

function InputStreamManager [1/2]

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

---

function InputStreamManager [2/2]

mediapipe::InputStreamManager::InputStreamManager () = default

---

function IsEmpty

bool mediapipe::InputStreamManager::IsEmpty () const

---

function IsFull

bool mediapipe::InputStreamManager::IsFull () const

---

function MaxQueueSize

int mediapipe::InputStreamManager::MaxQueueSize () const

---

function MinTimestampOrBound

Timestamp mediapipe::InputStreamManager::MinTimestampOrBound (
    bool * is_empty
) const

---

function MovePackets

absl::Status mediapipe::InputStreamManager::MovePackets (
    std::list< Packet > * container,
    bool * notify
) 

---

function Name

const std::string & mediapipe::InputStreamManager::Name () const

---

function NumPacketsAdded

int mediapipe::InputStreamManager::NumPacketsAdded () const

---

function PopPacketAtTimestamp

Packet mediapipe::InputStreamManager::PopPacketAtTimestamp (
    Timestamp timestamp,
    int * num_packets_dropped,
    bool * stream_is_done
) 

---

function PopQueueHead

Packet mediapipe::InputStreamManager::PopQueueHead (
    bool * stream_is_done
) 

---

function PrepareForRun

void mediapipe::InputStreamManager::PrepareForRun () 

---

function QueueHead

Packet mediapipe::InputStreamManager::QueueHead () const

---

function QueueSize

int mediapipe::InputStreamManager::QueueSize () const

---

function SetHeader

absl::Status mediapipe::InputStreamManager::SetHeader (
    const Packet & header
) 

---

function SetMaxQueueSize

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

---

function SetNextTimestampBound

absl::Status mediapipe::InputStreamManager::SetNextTimestampBound (
    Timestamp bound,
    bool * notify
) 

---

function SetQueueSizeCallbacks

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

---

function operator=

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

---

---

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