StreamScheduler Class

Declaration

class simaai::neat::graph::nodes::StreamScheduler { ... }

Included Headers

#include <StreamScheduler.h>

Base class

class	StageExecutor

Public Constructors Index

	StreamScheduler (StreamSchedulerOptions opt)

Public Member Functions Index

void	set_ports (const StagePorts &ports) override
void	on_input (StageMsg &&msg, std::vector< StageOutMsg > &out) override

Private Member Functions Index

void	ensure_stream_ (const std::string &stream_id)
bool	emit_one_ (std::vector< StageOutMsg > &out)

Private Member Attributes Index

StreamSchedulerOptions	opt_
std::unordered_map< std::string, std::deque< Sample > >	queues_
std::deque< std::string >	rr_order_
std::unordered_set< std::string >	active_
PortId	out_port_ = kInvalidPort

Definition at line 34 of file StreamScheduler.h.

Public Constructors

StreamScheduler()

simaai::neat::graph::nodes::StreamScheduler::StreamScheduler (StreamSchedulerOptions opt)

explicit

Definition at line 36 of file StreamScheduler.h.

Public Member Functions

on_input()

void simaai::neat::graph::nodes::StreamScheduler::on_input (StageMsg && msg, std::vector< StageOutMsg > & out)

virtual

Definition at line 39 of file StreamScheduler.h.

set_ports()

void simaai::neat::graph::nodes::StreamScheduler::set_ports (const StagePorts & ports)

virtual

Definition at line 38 of file StreamScheduler.h.

Private Member Functions

emit_one_()

bool simaai::neat::graph::nodes::StreamScheduler::emit_one_ (std::vector< StageOutMsg > & out)

Definition at line 43 of file StreamScheduler.h.

ensure_stream_()

void simaai::neat::graph::nodes::StreamScheduler::ensure_stream_ (const std::string & stream_id)

Definition at line 42 of file StreamScheduler.h.

Private Member Attributes

active_

std::unordered_set<std::string> simaai::neat::graph::nodes::StreamScheduler::active_

Definition at line 48 of file StreamScheduler.h.

48 std::unordered_set<std::string> active_;

opt_

StreamSchedulerOptions simaai::neat::graph::nodes::StreamScheduler::opt_

Definition at line 45 of file StreamScheduler.h.

45 StreamSchedulerOptions opt_;

out_port_

PortId simaai::neat::graph::nodes::StreamScheduler::out_port_ = kInvalidPort

Definition at line 49 of file StreamScheduler.h.

49 PortId out_port_ = kInvalidPort;

queues_

std::unordered_map<std::string, std::deque<Sample> > simaai::neat::graph::nodes::StreamScheduler::queues_

Definition at line 46 of file StreamScheduler.h.

46 std::unordered_map<std::string, std::deque<Sample>> queues_;

rr_order_

std::deque<std::string> simaai::neat::graph::nodes::StreamScheduler::rr_order_

Definition at line 47 of file StreamScheduler.h.

47 std::deque<std::string> rr_order_;

---

The documentation for this class was generated from the following file:

• StreamScheduler.h

---

Generated via doxygen2docusaurus 2.0.0 by Doxygen 1.9.1.