WireCell::Pgraph::Hydra Class Reference

#include <Wrappers.h>

Inheritance diagram for WireCell::Pgraph::Hydra:

Public Member Functions
	Hydra (INode::pointer wcnode)
virtual	~Hydra ()
virtual bool	operator() ()
Public Member Functions inherited from WireCell::Pgraph::PortedNode
	PortedNode (INode::pointer wcnode)
virtual std::string	ident ()
Public Member Functions inherited from WireCell::Pgraph::Node
	Node ()
virtual	~Node ()
Port &	iport (size_t ind=0)
Port &	oport (size_t ind=0)
PortList &	input_ports ()
PortList &	output_ports ()
Port &	port (Port::Type type, size_t ind=0)
Port &	port (Port::Type type, const std::string &name)
bool	connected ()

Private Attributes
IHydraNodeBase::pointer	m_wcnode

Additional Inherited Members
Protected Attributes inherited from WireCell::Pgraph::Node
PortList	m_ports [Port::ntypes]

Detailed Description

Definition at line 279 of file Wrappers.h.

Constructor & Destructor Documentation

WireCell::Pgraph::Hydra::Hydra ( INode::pointer  wcnode )

inline

Definition at line 282 of file Wrappers.h.

                                       : PortedNode(wcnode) {
                m_wcnode = std::dynamic_pointer_cast<IHydraNodeBase>(wcnode);
            }

virtual WireCell::Pgraph::Hydra::~Hydra ( )

inlinevirtual

Definition at line 285 of file Wrappers.h.

{ }

Member Function Documentation

virtual bool WireCell::Pgraph::Hydra::operator() ( void  )

inlinevirtual

Implements WireCell::Pgraph::Node.

Definition at line 287 of file Wrappers.h.

                                      {
                auto& iports = input_ports();
                size_t nin = iports.size();

                // 0) Hydra needs all input ports full to be ready.
                // For EOS, the concrete INode better retain the
                // terminating nullptr in its input stream.
                for (size_t ind=0; ind < nin; ++ind) {
                    if (iports[ind].empty()) {
                        return false;
                    }
                }

                // 1) fill input any queue vector
                IHydraNodeBase::any_queue_vector inqv(nin);
                for (size_t ind=0; ind < nin; ++ind) {
                    Edge edge = iports[ind].edge();
                    if (!edge) {
                        std::cerr << "Hydra: got broken edge\n";
                        continue;
                    }
                    if (edge->empty()) {
                        continue;
                    }
                    inqv[ind].insert(inqv[ind].begin(), edge->begin(), edge->end());
                }

                auto& oports = output_ports();
                size_t nout = oports.size();

                // 2) create output any queue vector
                IHydraNodeBase::any_queue_vector outqv(nout);

                // 3) call
                bool ok = (*m_wcnode)(inqv, outqv);
                if (!ok) { return false; } // fixme: this probably
                                           // needs to reflect into
                                           // ready().

                // 4) pop dfp input queues to match.  BIG FAT
                // WARNING: this trimming assumes calller only
                // pop_front's.  Really should hunt for which ones
                // have been removed.
                for (size_t ind=0; ind < nin; ++ind) {
                    size_t want = inqv[ind].size();
                    while (iports[ind].size() > want) {
                        iports[ind].get(); 
                    }
                }
                
                // 5) send out output any queue vectors
                for (size_t ind=0; ind < nout; ++ind) {
                    Edge edge = oports[ind].edge();
                    edge->insert(edge->end(), outqv[ind].begin(), outqv[ind].end());
                }

                return true;
            }

Member Data Documentation

IHydraNodeBase::pointer WireCell::Pgraph::Hydra::m_wcnode

private

Definition at line 280 of file Wrappers.h.

---

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

• wire-cell-build/pgraph/inc/WireCellPgraph/Wrappers.h