Hedgehog
3.1.0
A library to generate hybrid pipeline workflow systems
|
Switch core. More...
#include "core_switch.h"
Public Member Functions | |
template<class Switch > requires std::is_base_of_v<behavior::MultiSwitchRules<Inputs...>, Switch> | |
CoreSwitch (Switch *const multiSwitchRules) | |
Construct a CoreSwitch with a user-defined abstraction with switch rules. | |
~CoreSwitch () override=default | |
Default destructor. | |
template<tool::ContainsConcept< Inputs... > Input> | |
bool | callSendToGraph (std::shared_ptr< Input > &data, size_t const &graphId) |
Interface to user-defined switch rules. | |
std::vector< std::pair< std::string const, std::string const > > | ids () const override |
Node ids [nodeId, nodeGroupId] accessor. | |
behavior::Node * | node () const override |
Getter to the node counterpart. | |
![]() | |
NodeAbstraction (std::string name) | |
Core node constructor using the core's name. | |
virtual | ~NodeAbstraction ()=default |
DEfault destructor. | |
std::string const & | name () const |
Accessor to the core's name. | |
virtual std::string | id () const |
Core's id ('x' + address of abstraction) as string. | |
bool | isRegistered () const |
Accessor to registration flag. | |
GraphNodeAbstraction * | belongingGraph () const |
Belonging graph accessor. | |
virtual int | deviceId () const |
Get the device identifier (got from belonging graph) | |
virtual size_t | graphId () const |
Get the graph identifier (got from belonging graph) | |
std::chrono::nanoseconds const & | executionDuration () const |
Execution duration. | |
std::chrono::time_point< std::chrono::system_clock > const & | startExecutionTimeStamp () const |
Accessor to the starting execution timestamp. | |
void | startExecutionTimeStamp (std::chrono::time_point< std::chrono::system_clock > const &startExecutionTimeStamp) |
Setter to the starting execution timestamp. | |
void | incrementExecutionDuration (std::chrono::nanoseconds const &exec) |
Increment execution duration. | |
virtual void | registerNode (GraphNodeAbstraction *belongingGraph) |
Register node to the given graph. | |
virtual std::vector< std::pair< std::string const, std::string const > > | ids () const =0 |
Node ids [nodeId, nodeGroupId] accessor. | |
virtual behavior::Node * | node () const =0 |
Node accessor. | |
![]() | |
TaskOutputsManagementAbstraction () | |
Default constructor. | |
TaskOutputsManagementAbstraction (std::shared_ptr< implementor::ImplementorNotifier > concreteNotifier, std::shared_ptr< ConcreteMultiSenders > concreteMultiSenders) | |
Constructor using concrete implementation of the possible core abstraction. | |
~TaskOutputsManagementAbstraction () override=default | |
Default destructor. | |
void | sendAndNotify (std::shared_ptr< OutputDataType > data) |
Send a piece of data and notify the successors. | |
![]() | |
NotifierAbstraction (std::shared_ptr< implementor::ImplementorNotifier > notifier) | |
Constructor utilising a concrete implementation. | |
virtual | ~NotifierAbstraction ()=default |
Default destructor. | |
std::set< NotifierAbstraction * > const & | notifiers () const |
Const accessor to notifiers. | |
std::set< NotifierAbstraction * > & | notifiers () |
Accessor to notifiers. | |
void | addSlot (SlotAbstraction *const slot) |
Add a SlotAbstraction to this notifier. | |
void | removeSlot (SlotAbstraction *const slot) |
Remove SlotAbstraction from this notifier. | |
std::set< SlotAbstraction * > const & | connectedSlots () const |
Accessor to the slots attached to this notifier. | |
void | notify () |
Notify a slot to wake up. | |
void | notifyAllTerminated () |
Notifier all slots that this node is terminated. | |
![]() | |
SenderAbstraction (std::shared_ptr< implementor::ImplementorSender< Outputs > > concreteSender) | |
Constructor using the concrete implementation. | |
virtual | ~SenderAbstraction ()=default |
Default destructor. | |
std::set< SenderAbstraction< Outputs > * > const & | senders () const |
Const accessor to senders. | |
std::set< SenderAbstraction< Outputs > * > & | senders () |
Accessor to senders. | |
std::set< ReceiverAbstraction< Outputs > * > const & | connectedReceivers () const |
Accessor to the receivers attached to this SenderAbstraction. | |
void | addReceiver (ReceiverAbstraction< Outputs > *const receiver) |
Add a ReceiverAbstraction. | |
void | removeReceiver (ReceiverAbstraction< Outputs > *const receiver) |
Remove a ReceiverAbstraction. | |
void | send (std::shared_ptr< Outputs > data) |
Send a data as output of the node. | |
Private Attributes | |
behavior::MultiSwitchRules< Inputs... > *const | multiSwitchRules_ = nullptr |
User-defined abstraction with switch rules. | |
Additional Inherited Members | |
![]() | |
using | outputs_t = std::tuple< Outputs... > |
Accessor to the graph outputs type. | |
![]() | |
void | copyInnerStructure (TaskOutputsManagementAbstraction< Outputs... > *copyableCore) |
Copy the inner structure from another task. | |
void | duplicateOutputEdges (std::map< abstraction::NodeAbstraction *, std::shared_ptr< NodeAbstraction > > &mapping) |
Duplicate the output edges for the node clone. | |
![]() | |
void | duplicateEdgeNotifier (std::map< abstraction::NodeAbstraction *, std::shared_ptr< NodeAbstraction > > &mapping) |
Duplicate edges of the current notifier to slots to clone in map. | |
![]() | |
void | copyInnerStructure (SenderAbstraction< Outputs > *copyableCore) |
Copy inner structure of the sender to this one. | |
void | duplicateEdgeSender (std::map< abstraction::NodeAbstraction *, std::shared_ptr< NodeAbstraction > > &mapping) |
Duplicate edges of the current sender to receiver to clone in map. | |
Switch core.
Inputs | Input types list |
Definition at line 35 of file core_switch.h.
|
inlineexplicit |
Construct a CoreSwitch with a user-defined abstraction with switch rules.
Switch | Type of the user-defined abstraction with switch rules |
multiSwitchRules | User-defined abstraction with switch rules |
Definition at line 48 of file core_switch.h.
|
overridedefault |
Default destructor.
|
inline |
Interface to user-defined switch rules.
Input | Input data type |
data | Input data |
graphId | Graph id |
Definition at line 61 of file core_switch.h.
|
inlineoverridevirtual |
Node ids [nodeId, nodeGroupId] accessor.
Implements hh::core::abstraction::NodeAbstraction.
Definition at line 67 of file core_switch.h.
|
inlineoverridevirtual |
Getter to the node counterpart.
std::runtime_error | because there is no Node attached to the core |
Implements hh::core::abstraction::NodeAbstraction.
Definition at line 74 of file core_switch.h.
|
private |
User-defined abstraction with switch rules.
Definition at line 40 of file core_switch.h.