#include <Sync.hpp>

Inheritance diagram for dai::node::Sync:

Public Member Functions
int	getSyncAttempts () const

std::chrono::nanoseconds	getSyncThreshold () const

void	setSyncAttempts (int syncAttempts)

void	setSyncThreshold (std::chrono::nanoseconds syncThreshold)

	Sync (const std::shared_ptr< PipelineImpl > &par, int64_t nodeId)

	Sync (const std::shared_ptr< PipelineImpl > &par, int64_t nodeId, std::unique_ptr< Properties > props)

Public Member Functions inherited from dai::NodeCRTP< Node, Sync, SyncProperties >
std::unique_ptr< Node >	clone () const override

const char *	getName () const override

Public Member Functions inherited from dai::Node
virtual std::unique_ptr< Node >	clone () const =0
	Deep copy the node. More...

AssetManager &	getAssetManager ()
	Get node AssetManager as a reference. More...

const AssetManager &	getAssetManager () const
	Get node AssetManager as a const reference. More...

std::vector< Input * >	getInputRefs ()
	Retrieves reference to node inputs. More...

std::vector< const Input * >	getInputRefs () const
	Retrieves reference to node inputs. More...

std::vector< Input >	getInputs ()
	Retrieves all nodes inputs. More...

virtual const char *	getName () const =0
	Retrieves nodes name. More...

std::vector< Output * >	getOutputRefs ()
	Retrieves reference to node outputs. More...

std::vector< const Output * >	getOutputRefs () const
	Retrieves reference to node outputs. More...

std::vector< Output >	getOutputs ()
	Retrieves all nodes outputs. More...

Pipeline	getParentPipeline ()

const Pipeline	getParentPipeline () const

	Node (const std::shared_ptr< PipelineImpl > &p, Id nodeId, std::unique_ptr< Properties > props)
	Constructs Node. More...

virtual	~Node ()=default

Public Attributes
InputMap	inputs

Output	out {*this, "out", Output::Type::MSender, {{DatatypeEnum::MessageGroup, false}}}

Public Attributes inherited from dai::NodeCRTP< Node, Sync, SyncProperties >
Properties &	properties
	Underlying properties. More...

Public Attributes inherited from dai::Node
const Id	id
	Id of node. More...

Properties &	properties

Static Public Attributes
constexpr static const char *	NAME = "Sync"

Additional Inherited Members
Public Types inherited from dai::NodeCRTP< Node, Sync, SyncProperties >
using	Properties = SyncProperties

Public Types inherited from dai::Node
using	Id = std::int64_t
	Node identificator. Unique for every node on a single Pipeline. More...

Protected Member Functions inherited from dai::Node
virtual Properties &	getProperties ()

virtual tl::optional< OpenVINO::Version >	getRequiredOpenVINOVersion ()

void	setInputMapRefs (InputMap *inMapRef)

void	setInputMapRefs (std::initializer_list< InputMap * > l)

void	setInputRefs (Input *inRef)

void	setInputRefs (std::initializer_list< Input * > l)

void	setOutputMapRefs (OutputMap *outMapRef)

void	setOutputMapRefs (std::initializer_list< OutputMap * > l)

void	setOutputRefs (Output *outRef)

void	setOutputRefs (std::initializer_list< Output * > l)

Protected Attributes inherited from dai::Node
AssetManager	assetManager

std::unordered_map< std::string, InputMap * >	inputMapRefs

std::unordered_map< std::string, Input * >	inputRefs

std::unordered_map< std::string, OutputMap * >	outputMapRefs

std::unordered_map< std::string, Output * >	outputRefs

std::weak_ptr< PipelineImpl >	parent

copyable_unique_ptr< Properties >	propertiesHolder

Detailed Description

Definition at line 11 of file Sync.hpp.

Constructor & Destructor Documentation

◆ Sync() [1/2]

dai::node::Sync::Sync	(	const std::shared_ptr< PipelineImpl > &	par,
		int64_t	nodeId
	)

Definition at line 6 of file Sync.cpp.

◆ Sync() [2/2]

dai::node::Sync::Sync	(	const std::shared_ptr< PipelineImpl > &	par,
		int64_t	nodeId,
		std::unique_ptr< Properties >	props
	)

Definition at line 7 of file Sync.cpp.

Member Function Documentation

◆ getSyncAttempts()

int dai::node::Sync::getSyncAttempts ( ) const

Gets the number of sync attempts

Definition at line 26 of file Sync.cpp.

◆ getSyncThreshold()

std::chrono::nanoseconds dai::node::Sync::getSyncThreshold ( ) const

Gets the maximal interval between messages in the group in milliseconds

Definition at line 22 of file Sync.cpp.

◆ setSyncAttempts()

void dai::node::Sync::setSyncAttempts ( int syncAttempts )

Set the number of attempts to get the specified max interval between messages in the group

Parameters

syncAttempts

Number of attempts to get the specified max interval between messages in the group:

if syncAttempts = 0 then the node sends a message as soon at the group is filled
if syncAttempts > 0 then the node will make syncAttemts attempts to synchronize before sending out a message
if syncAttempts = -1 (default) then the node will only send a message if successfully synchronized

Definition at line 18 of file Sync.cpp.

◆ setSyncThreshold()

void dai::node::Sync::setSyncThreshold ( std::chrono::nanoseconds syncThreshold )

Set the maximal interval between messages in the group

Parameters

syncThreshold Maximal interval between messages in the group

Definition at line 14 of file Sync.cpp.

Member Data Documentation

◆ inputs

InputMap dai::node::Sync::inputs

A map of inputs

Definition at line 21 of file Sync.hpp.

◆ NAME

constexpr static const char* dai::node::Sync::NAME = "Sync"

staticconstexpr

Definition at line 13 of file Sync.hpp.

◆ out

Output dai::node::Sync::out {*this, "out", Output::Type::MSender, {{DatatypeEnum::MessageGroup, false}}}

Output message of type MessageGroup

Definition at line 26 of file Sync.hpp.

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

Public Member Functions

Public Attributes

Static Public Attributes

Additional Inherited Members