Asynchronous node base class. More...

#include <async_node.h>

Inheritance diagram for mf::flow::async_node:

Public Member Functions
	async_node (graph &)

	~async_node ()

void	internal_setup () finaloverride
	Called by propagate_setup_. More...

void	launch () finaloverride
	Called by graph for all nodes, before any frame is pulled from sink. More...

void	stop () finaloverride
	Called by graph for all node, before destruction of any node. More...

bool	process_next_frame () override

node_input &	add_input (time_unit past_window, time_unit future_window) override

async_node_output &	add_output (const frame_format &format) override

Public Member Functions inherited from mf::flow::filter_node
	filter_node (graph &gr)

	~filter_node ()

template<typename Filter , typename... Args>
Filter &	set_filter (Args &&...args)

filter &	this_filter ()

const filter &	this_filter () const

Public Member Functions inherited from mf::flow::node
virtual	~node ()

graph &	this_graph () noexcept

void	define_source_stream_properties (bool seekable, time_unit stream_duration=-1)

void	set_prefetch_duration (time_unit)

const auto &	inputs () noexcept

const auto &	outputs () noexcept

bool	is_source () const noexcept

bool	is_sink () const noexcept

time_unit	end_time () const noexcept

bool	reached_end () const noexcept

bool	was_setup () const noexcept

time_unit	prefetch_duration () const noexcept

time_unit	offset () const noexcept

bool	stream_duration_is_defined () const noexcept

time_unit	stream_duration () const noexcept

bool	is_seekable () const noexcept

bool	is_bounded () const

bool	is_active () const noexcept

void	update_activation ()
	Called by output, propagates to preceding nodes. More...

time_unit	current_time () const noexcept

Additional Inherited Members
Public Attributes inherited from mf::flow::node
std::string	name

Protected Member Functions inherited from mf::flow::filter_node
void	setup_filter ()

void	pre_process_filter (node_job &)

void	process_filter (node_job &)

Protected Member Functions inherited from mf::flow::node
	node (graph &gr)

	node (const node &)=delete

node &	operator= (const node &)=delete

void	setup_sink ()
	Called by sink node, runs set up procedure for all node in graph. More...

void	set_current_time (time_unit t) noexcept

void	mark_end ()

node_job	make_job ()

void	cancel_job (node_job &)

template<typename Input >
Input &	add_input_ (time_unit past_window, time_unit future_window)

template<typename Output >
Output &	add_output_ (const frame_format &format)

Detailed Description

Asynchronous node base class.

Processes frames in a separate thread owned by the node. Can have multiple inputs, but only one output. Can process frames t+k (k <= 1), at the same time that current frame t is being read or processed by suceeding nodes in graph.