Midge
v3.9.2
Data Processing Framework
|
#include <diptera.hh>
Public Member Functions | |
diptera () | |
~diptera () | |
void | add (node *p_node) |
Add a node. More... | |
void | connect (const std::string &p_string) |
Connect a signal to a slot: signal_node.signal:slot_node.slot. More... | |
void | join (const std::string &p_string) |
Join one node to another. More... | |
std::exception_ptr | run (const std::string &p_string) |
void | throw_ex (std::exception_ptr e_ptr) |
To be used by running nodes to throw an exception. More... | |
void | reset () |
void | instruct (instruction p_inst) |
void | set_running_callback (std::function< void() > a_callback) |
Static Public Member Functions | |
static const std::string & | connector () |
static const std::string & | designator () |
static const std::string & | separator () |
Private Types | |
typedef std::map< std::string, node *> | node_map_t |
typedef node_map_t::iterator | node_it_t |
typedef node_map_t::const_iterator | node_cit_t |
typedef node_map_t::value_type | node_entry_t |
typedef std::set< instructable *> | inst_set_t |
typedef inst_set_t::iterator | inst_it_t |
typedef inst_set_t::const_iterator | inst_cit_t |
typedef inst_set_t::value_type | inst_entry_t |
typedef std::vector< std::thread > | thread_vector_t |
typedef thread_vector_t::iterator | thread_it_t |
typedef thread_vector_t::const_iterator | thread_cit_t |
Private Member Functions | |
virtual void | do_cancellation (int a_code) |
virtual void | do_reset_cancellation () |
Private Attributes | |
node_map_t | f_nodes |
inst_set_t | f_instructables |
thread_vector_t | f_threads |
std::mutex | f_threads_mutex |
std::exception_ptr | f_run_e_ptr |
std::function< void() > | f_running_callback |
Static Private Attributes | |
static const std::string | s_connector = string_t( ":" ) |
static const std::string | s_designator = string_t( "." ) |
static const std::string | s_separator = string_t( ":" ) |
Definition at line 20 of file diptera.hh.
|
private |
Definition at line 75 of file diptera.hh.
|
private |
Definition at line 76 of file diptera.hh.
|
private |
Definition at line 74 of file diptera.hh.
|
private |
Definition at line 73 of file diptera.hh.
|
private |
Definition at line 68 of file diptera.hh.
|
private |
Definition at line 69 of file diptera.hh.
|
private |
Definition at line 67 of file diptera.hh.
|
private |
Definition at line 66 of file diptera.hh.
|
private |
Definition at line 82 of file diptera.hh.
|
private |
Definition at line 81 of file diptera.hh.
|
private |
Definition at line 80 of file diptera.hh.
diptera | ( | ) |
Definition at line 24 of file diptera.cc.
~diptera | ( | ) |
Definition at line 34 of file diptera.cc.
void add | ( | node * | p_node | ) |
Add a node.
Definition at line 39 of file diptera.cc.
void connect | ( | const std::string & | p_string | ) |
Connect a signal to a slot: signal_node.signal:slot_node.slot.
Definition at line 72 of file diptera.cc.
|
static |
Definition at line 484 of file diptera.cc.
|
static |
Definition at line 489 of file diptera.cc.
|
privatevirtual |
Definition at line 415 of file diptera.cc.
|
privatevirtual |
Definition at line 467 of file diptera.cc.
void instruct | ( | instruction | p_inst | ) |
Definition at line 403 of file diptera.cc.
void join | ( | const std::string & | p_string | ) |
Join one node to another.
Option 1: Join by data stream "my-producer.out_0:my-consumer.in_0" Output 0 of my-producer will be connected to input 0 of my-consumer
Option 2: Join by pointer "my-consumer:my-producer" my-consumer will get a pointer to my-producer stored in the f_node_links map
Definition at line 147 of file diptera.cc.
void reset | ( | ) |
Definition at line 379 of file diptera.cc.
std::exception_ptr run | ( | const std::string & | p_string | ) |
Run a set of nodes; only the nodes specified will be executed "my-consumer:my-producer"
Definition at line 269 of file diptera.cc.
|
static |
Definition at line 494 of file diptera.cc.
|
inline |
Definition at line 96 of file diptera.hh.
void throw_ex | ( | std::exception_ptr | e_ptr | ) |
To be used by running nodes to throw an exception.
Definition at line 347 of file diptera.cc.
|
private |
Definition at line 78 of file diptera.hh.
|
private |
Definition at line 71 of file diptera.hh.
|
private |
Definition at line 87 of file diptera.hh.
|
private |
Definition at line 89 of file diptera.hh.
|
private |
Definition at line 84 of file diptera.hh.
|
private |
Definition at line 85 of file diptera.hh.
Definition at line 91 of file diptera.hh.
Definition at line 92 of file diptera.hh.
Definition at line 93 of file diptera.hh.