WireCell::Gen::DepoMerger Class Reference

#include <DepoMerger.h>

Inheritance diagram for WireCell::Gen::DepoMerger:

Public Member Functions
	DepoMerger ()
virtual	~DepoMerger ()
virtual bool	operator() (input_queues_type &inqs, output_queues_type &outqs)
	Typed interface for subclass to implement. 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::IDepoMerger
virtual	~IDepoMerger ()
virtual std::string	signature ()
Public Member Functions inherited from WireCell::IHydraNode< std::tuple< IDepo, IDepo >, std::tuple< IDepo > >
virtual	~IHydraNode ()
virtual bool	operator() (any_queue_vector &anyinq, any_queue_vector &anyoutq)
	Translate call from any to types and back. More...
virtual std::vector< std::string >	input_types ()
virtual std::vector< std::string >	output_types ()
Public Member Functions inherited from WireCell::IHydraNodeBase
virtual	~IHydraNodeBase ()
virtual NodeCategory	category ()
	Return the behavior category type. More...
virtual int	concurrency ()
	By default assume hydra nodes can do their thing stateless. More...
Public Member Functions inherited from WireCell::INode
virtual	~INode ()
virtual void	reset ()
Public Member Functions inherited from WireCell::IComponent< INode >
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
int	m_nin0
int	m_nin1
int	m_nout
bool	m_eos

Additional Inherited Members
Public Types inherited from WireCell::IDepoMerger
typedef std::shared_ptr< IDepoMerger >	pointer
Public Types inherited from WireCell::IHydraNode< std::tuple< IDepo, IDepo >, std::tuple< IDepo > >
typedef std::tuple< IDepo, IDepo >	input_tuple_type
typedef std::tuple< IDepo >	output_tuple_type
typedef shared_queued< std::tuple< IDepo, IDepo > >	input_shqed
typedef shared_queued< std::tuple< IDepo > >	output_shqed
typedef input_shqed::shared_queued_tuple_type	input_queues_type
typedef output_shqed::shared_queued_tuple_type	output_queues_type
Public Types inherited from WireCell::IHydraNodeBase
typedef std::shared_ptr< IHydraNodeBase >	pointer
typedef std::deque< boost::any >	any_queue
typedef std::vector< any_queue >	any_queue_vector
Public Types inherited from WireCell::INode
enum	NodeCategory {   unknown, sourceNode, sinkNode, functionNode,   queuedoutNode, joinNode, splitNode, faninNode,   fanoutNode, multioutNode, hydraNode }
Public Types inherited from WireCell::IComponent< INode >
typedef std::shared_ptr< INode >	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 10 of file DepoMerger.h.

Constructor & Destructor Documentation

Gen::DepoMerger::DepoMerger

(

)

Definition at line 12 of file DepoMerger.cxx.

    : m_nin0(0), m_nin1(0), m_nout(0), m_eos(false)
{
}

Gen::DepoMerger::~DepoMerger ( )

virtual

Definition at line 16 of file DepoMerger.cxx.

{
}

Member Function Documentation

void Gen::DepoMerger::configure ( const WireCell::Configuration &  config )

virtual

Accept a configuration.

Implements WireCell::IConfigurable.

Definition at line 93 of file DepoMerger.cxx.

{
}

WireCell::Configuration Gen::DepoMerger::default_configuration ( ) const

virtual

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

Reimplemented from WireCell::IConfigurable.

Definition at line 97 of file DepoMerger.cxx.

{
    Configuration cfg;
    return cfg;
}

bool Gen::DepoMerger::operator() ( input_queues_type &  inqs, output_queues_type &  outqs  )

virtual

Typed interface for subclass to implement.

Implements WireCell::IHydraNode< std::tuple< IDepo, IDepo >, std::tuple< IDepo > >.

Definition at line 21 of file DepoMerger.cxx.

{
    if (m_eos) {                // already closed off all our outputs
        return false;
    }

    auto& inq0 = get<0>(inqs);
    auto& inq1 = get<1>(inqs);

    if (inq0.empty() or inq1.empty()) {
        std::cerr << "DepoMerger: called empty input\n";
        return false;
    }

    auto& outq = get<0>(outqs);

    //std::cerr << "DepoMerger queue sizes on input: in:["<< inq0.size()<<","<<inq1.size()<<"], "
    //          << "out:["<<outq.size()<<"]\n";

    IDepo::pointer d0 = inq0.front();
    IDepo::pointer d1 = inq1.front();

    if (d0 and d1) {
        double t0 = d0->time(); // keep the newest one
        double t1 = d1->time(); // which may be both if they coincide
        if (t0 <= t1) {
            ++m_nout;
            ++m_nin0;
            outq.push_back(d0);
            inq0.pop_front();
            //std::cerr << "DepoMerger: stream 0 output: t0="<<t0<<", t1="<<t1<<"\n"; 
        }
        if (t1 <= t0) {
            ++m_nout;
            ++m_nin1;
            outq.push_back(d1);
            inq1.pop_front();
            //std::cerr << "DepoMerger: stream 1 output: t0="<<t0<<", t1="<<t1<<"\n"; 
        }
        return true;
    }   

    if (d0) {                   // d1 is eos
        ++m_nout;
        ++m_nin0;
        outq.push_back(d0);
        inq0.pop_front();
        //std::cerr << "DepoMerger: stream 0 only output: nout="<<m_nout<<"\n"; 
        return true;
    }

    if (d1) {                   // d0 is eos
        ++m_nout;
        ++m_nin1;
        outq.push_back(d1);
        inq1.pop_front();
        //std::cerr << "DepoMerger: stream 1 only output: nout="<<m_nout<<"\n"; 
        return true;
    }

    // both are eos for the first time.
    m_eos = true;
    outq.push_back(nullptr);
    std::cerr << "DepoMerger: global EOS: in: "
              << m_nin0 << " + " << m_nin1
              << ", out: " << m_nout << " depos\n";

    return true;
}

Member Data Documentation

bool WireCell::Gen::DepoMerger::m_eos

private

Definition at line 27 of file DepoMerger.h.

int WireCell::Gen::DepoMerger::m_nin0

private

Definition at line 26 of file DepoMerger.h.

int WireCell::Gen::DepoMerger::m_nin1

private

Definition at line 26 of file DepoMerger.h.

int WireCell::Gen::DepoMerger::m_nout

private

Definition at line 26 of file DepoMerger.h.

---

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

• wire-cell-build/gen/inc/WireCellGen/DepoMerger.h
• wire-cell-build/gen/src/DepoMerger.cxx