Falcon
Loading...
Searching...
No Matches
graph::ProcessorGraph Class Reference

Public Member Functions

 ProcessorGraph (GlobalContext &context)
bool terminated ()
bool done ()
bool all_processors_running ()
bool any_processor_running ()
void ConstructProcessorEngines (const YAML::Node &node)
YAML::Node GetProcessorDocumentation ()
void Build (const YAML::Node &node)
void Destroy ()
void StartProcessing (const std::string &run_group_id, const std::string &run_id, const std::string &template_id, bool test_flag)
void StopProcessing ()
void Update (YAML::Node &node)
void Retrieve (YAML::Node &node)
void Apply (YAML::Node &node)
std::string ExportYAML ()
GraphState state () const
std::string state_string () const
void set_state (GraphState state)
const ProcessorMap & processors () const
const StreamConnections & connections () const
IProcessor * LookUpProcessor (const std::string &name)
std::vector< std::pair< std::string, std::shared_ptr< IState > > > LookUpStates (const std::vector< std::string > &state_addresses)
void BuildSharedStates (const YAML::Node &node)

Protected Member Functions

void CreateConnection (SlotAddress &out, SlotAddress &in)

Member Function Documentation

◆ Apply()

void ProcessorGraph::Apply ( YAML::Node & node)

Apply exposed methods with parameters given in the yaml node

Parameters
nodeexposed method description

◆ Build()

void ProcessorGraph::Build ( const YAML::Node & node)

Build the graph

Construct all processors, parse and create connections between them and create shared state.

Parameters
nodegraph description

◆ ConstructProcessorEngines()

void ProcessorGraph::ConstructProcessorEngines ( const YAML::Node & node)

Construct processors listed in the graph yaml description.

Looping through the graph description to find every processor, expanded their name, create their instance and run the internal configuration for each.

Parameters
nodegraph description

◆ GetProcessorDocumentation()

YAML::Node ProcessorGraph::GetProcessorDocumentation ( )

Give the documentation of either all registered processor or only processors used in the running graph

◆ Retrieve()

void ProcessorGraph::Retrieve ( YAML::Node & node)

Retrieve the state value for all shared state name given in the yaml node.

Parameters
nodeshared state description

◆ Update()

void ProcessorGraph::Update ( YAML::Node & node)

Update processor's shared state with input from the user

Parameters
nodegraph description

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