WireCellTbb::TbbFlow Class Reference

#include <TbbFlow.h>

Inheritance diagram for WireCellTbb::TbbFlow:

Public Member Functions
	TbbFlow ()
virtual	~TbbFlow ()
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...
virtual void	execute ()
	Implement to run something. More...
Public Member Functions inherited from WireCell::IApplication
virtual	~IApplication ()
Public Member Functions inherited from WireCell::IComponent< IApplication >
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
WireCell::IDataFlowGraph::pointer	m_dfp
WireCell::DfpGraph	m_dfpgraph

Additional Inherited Members
Public Types inherited from WireCell::IComponent< IApplication >
typedef std::shared_ptr< IApplication >	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 11 of file TbbFlow.h.

Constructor & Destructor Documentation

TbbFlow::TbbFlow

(

)

Definition at line 15 of file TbbFlow.cxx.

{
}

TbbFlow::~TbbFlow ( )

virtual

Definition at line 19 of file TbbFlow.cxx.

{
}

Member Function Documentation

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

virtual

Accept a configuration.

Implements WireCell::IConfigurable.

Definition at line 34 of file TbbFlow.cxx.

{
    std::string type, name, desc = get<std::string>(cfg, "dfp","TbbDataFlowGraph");
    std::tie(type,name) = String::parse_pair(desc);
    m_dfp = Factory::lookup<IDataFlowGraph>(type, name);

    m_dfpgraph.configure(cfg["graph"]);
    
}

Configuration TbbFlow::default_configuration ( ) const

virtual

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

Reimplemented from WireCell::IConfigurable.

Definition at line 23 of file TbbFlow.cxx.

{
    std::string json = R"(
{
"dfp": "TbbDataFlowGraph",
"graph":[]
}
)";
    return Persist::loads(json);
}

void TbbFlow::execute ( )

virtual

Implement to run something.

Implements WireCell::IApplication.

Definition at line 44 of file TbbFlow.cxx.

{
    if (!m_dfp) {
        std::cerr << "TbbFlow: not configured\n";
        return;
    }

    std::cerr << "TbbFlow::Execute\n";

    for (auto thc : m_dfpgraph.connections()) {
        auto tail_tn = get<0>(thc);
        auto head_tn = get<1>(thc);
        auto conn = get<2>(thc);

        std::cerr << "TbbFlow: Connect: "
                  <<  tail_tn.type << ":" << tail_tn.name
                  << " ( " << conn.tail << " -> " << conn.head << " ) "
                  << head_tn.type << ":" << head_tn.name << "\n";

        INode::pointer tail_node = WireCell::Factory::lookup<INode>(tail_tn.type, tail_tn.name);
        INode::pointer head_node = WireCell::Factory::lookup<INode>(head_tn.type, head_tn.name);

        m_dfp->connect(tail_node, head_node, conn.tail, conn.head);
    }


    m_dfp->run();
}

Member Data Documentation

WireCell::IDataFlowGraph::pointer WireCellTbb::TbbFlow::m_dfp

private

Definition at line 12 of file TbbFlow.h.

WireCell::DfpGraph WireCellTbb::TbbFlow::m_dfpgraph

private

Definition at line 13 of file TbbFlow.h.

---

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

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