WireCellTbb::DataFlowGraph Class Reference

#include <DataFlowGraph.h>

Inheritance diagram for WireCellTbb::DataFlowGraph:

Public Member Functions
	DataFlowGraph (int max_threads=0)
virtual	~DataFlowGraph ()
virtual bool	connect (WireCell::INode::pointer tail, WireCell::INode::pointer head, size_t tail_port=0, size_t head_port=0)
virtual bool	run ()
	Run the graph, return false on error. More...
virtual void	configure (const WireCell::Configuration &config)
	Accept a configuration. More...
virtual WireCell::Configuration	default_configuration () const
	Optional, override to return a hard-coded default configuration. More...
Public Member Functions inherited from WireCell::IDataFlowGraph
virtual	~IDataFlowGraph ()
Public Member Functions inherited from WireCell::IComponent< IDataFlowGraph >
virtual	~IComponent ()
Public Member Functions inherited from WireCell::Interface
virtual	~Interface ()
Public Member Functions inherited from WireCell::IConfigurable
virtual	~IConfigurable ()
Public Member Functions inherited from WireCell::IComponent< IConfigurable >
virtual	~IComponent ()

Private Attributes
tbb::task_scheduler_init	m_sched
tbb::flow::graph	m_graph
WrapperFactory	m_factory

Additional Inherited Members
Public Types inherited from WireCell::IComponent< IDataFlowGraph >
typedef std::shared_ptr< IDataFlowGraph >	pointer
	Access subclass facet by pointer. More...
typedef std::vector< pointer >	vector
	Vector of shared pointers. More...
Public Types inherited from WireCell::Interface
typedef std::shared_ptr< Interface >	pointer
Public Types inherited from WireCell::IComponent< IConfigurable >
typedef std::shared_ptr< IConfigurable >	pointer
	Access subclass facet by pointer. More...
typedef std::vector< pointer >	vector
	Vector of shared pointers. More...

Detailed Description

Definition at line 16 of file DataFlowGraph.h.

Constructor & Destructor Documentation

DataFlowGraph::DataFlowGraph

(

int

max_threads = 0

)

Definition at line 19 of file DataFlowGraph.cxx.

    : m_sched(max_threads > 0 ? max_threads : tbb::task_scheduler_init::automatic)
    , m_graph()
    , m_factory(m_graph)
{
}

DataFlowGraph::~DataFlowGraph ( )

virtual

Definition at line 26 of file DataFlowGraph.cxx.

{
}

Member Function Documentation

void DataFlowGraph::configure ( const WireCell::Configuration &  config )

virtual

Accept a configuration.

Implements WireCell::IConfigurable.

Definition at line 38 of file DataFlowGraph.cxx.

{
    // int maxthreads = get<int>(cfg,"max_threads");
    // fixme: now what?
}

bool DataFlowGraph::connect ( WireCell::INode::pointer  tail, WireCell::INode::pointer  head, size_t  tail_port = 0, size_t  head_port = 0  )

virtual

Connect two nodes so that data runs from tail to head. Return false on error.

Implements WireCell::IDataFlowGraph.

Definition at line 45 of file DataFlowGraph.cxx.

{
    using namespace WireCellTbb;

    Node mytail = m_factory(tail);
    if (!mytail) {
        cerr << "DFP: failed to get tail node wrapper for "
             << demangle(tail->signature()) << endl;
        return false;
    }

    Node myhead = m_factory(head);
    if (!myhead) {
        cerr << "DFP: failed to get head node wrapper for "
             << demangle(head->signature()) << endl;
        return false;
    }

    auto sports = mytail->sender_ports();
    if (sport < 0 || sports.size() <= sport) {
        cerr << "DFP: bad sender port number: " << sport << endl;
        return false;
    }

    auto rports = myhead->receiver_ports();
    if (rport < 0 || rports.size() <= rport) {
        cerr << "DFP: bad receiver port number: " << rport << endl;
        return false;
    }

    
    sender_type* s = sports[sport];
    if (!s) {
        cerr << "DFP: failed to get sender port " << sport << endl;
        return false;
    }

    receiver_type* r = rports[rport];
    if (!s) {
        cerr << "DFP: failed to get receiver port " << rport << endl;
        return false;
    }


    //cerr << "Connecting " << s << " and " << r << endl;
    make_edge(*s, *r);
    return true;
}

Configuration DataFlowGraph::default_configuration ( ) const

virtual

Optional, override to return a hard-coded default configuration.

Reimplemented from WireCell::IConfigurable.

Definition at line 30 of file DataFlowGraph.cxx.

{
    Configuration cfg;
    cfg["max_threads"] = 1;
    return cfg;
}

bool DataFlowGraph::run ( )

virtual

Run the graph, return false on error.

Implements WireCell::IDataFlowGraph.

Definition at line 96 of file DataFlowGraph.cxx.

{
    for (auto it : m_factory.seen()) {
        cerr << "Initialize node of type: " << demangle(it.first->signature()) << endl;
        it.second->initialize();
    }
    m_graph.wait_for_all();
    return true;
}

Member Data Documentation

WrapperFactory WireCellTbb::DataFlowGraph::m_factory

private

Definition at line 36 of file DataFlowGraph.h.

tbb::flow::graph WireCellTbb::DataFlowGraph::m_graph

private

Definition at line 35 of file DataFlowGraph.h.

tbb::task_scheduler_init WireCellTbb::DataFlowGraph::m_sched

private

Definition at line 34 of file DataFlowGraph.h.

---

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

• wire-cell-build/tbb/inc/WireCellTbb/DataFlowGraph.h
• wire-cell-build/tbb/src/DataFlowGraph.cxx