WireCell::Gen::DepoChunker Class Reference

#include <DepoChunker.h>

Inheritance diagram for WireCell::Gen::DepoChunker:

Public Member Functions
	DepoChunker ()
virtual	~DepoChunker ()
virtual bool	operator() (const input_pointer &depo, output_queue &deposetqueue)
	The calling signature: 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::IDepoCollector
virtual	~IDepoCollector ()
virtual std::string	signature ()
Public Member Functions inherited from WireCell::IQueuedoutNode< IDepo, IDepoSet >
virtual	~IQueuedoutNode ()
virtual bool	operator() (const boost::any &anyin, queuedany &outanyq)
	The calling signature: More...
virtual std::vector< std::string >	input_types ()
virtual std::vector< std::string >	output_types ()
Public Member Functions inherited from WireCell::IQueuedoutNodeBase
virtual	~IQueuedoutNodeBase ()
virtual NodeCategory	category ()
	Return the behavior category type. More...
virtual int	concurrency ()
	By default assume all subclasses maintain state. 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 Member Functions
void	emit (output_queue &out)

Private Attributes
int	m_count
std::pair< double, double >	m_gate
std::pair< double, double >	m_starting_gate
IDepo::vector	m_depos

Additional Inherited Members
Public Types inherited from WireCell::IDepoCollector
typedef std::shared_ptr< IDepoCollector >	pointer
Public Types inherited from WireCell::IQueuedoutNode< IDepo, IDepoSet >
typedef std::shared_ptr< IQueuedoutNodeBase >	pointer
typedef IDepo	input_type
typedef IDepoSet	output_type
typedef std::shared_ptr< const IDepo >	input_pointer
typedef std::shared_ptr< const IDepoSet >	output_pointer
typedef std::deque< output_pointer >	output_queue
Public Types inherited from WireCell::IQueuedoutNodeBase
typedef std::shared_ptr< IQueuedoutNodeBase >	pointer
typedef std::deque< boost::any >	queuedany
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 26 of file DepoChunker.h.

Constructor & Destructor Documentation

Gen::DepoChunker::DepoChunker

(

)

Definition at line 11 of file DepoChunker.cxx.

    : m_count(0)
    , m_gate(0,0)
    , m_starting_gate(0,0)
{

}

Gen::DepoChunker::~DepoChunker ( )

virtual

Definition at line 19 of file DepoChunker.cxx.

{
}

Member Function Documentation

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

virtual

Accept a configuration.

Implements WireCell::IConfigurable.

Definition at line 34 of file DepoChunker.cxx.

{
    m_starting_gate = m_gate = std::pair<double,double>(cfg["gate"][0].asDouble(),
                                                        cfg["gate"][1].asDouble());
}

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

virtual

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

Set the time gate with a two element array of times. Only depos within the gate are output.

Reimplemented from WireCell::IConfigurable.

Definition at line 23 of file DepoChunker.cxx.

{
    Configuration cfg;

    /// Set the time gate with a two element array of times.  Only
    /// depos within the gate are output.
    cfg["gate"] = Json::arrayValue;

    return cfg;
}

void Gen::DepoChunker::emit ( output_queue &  out )

private

Definition at line 40 of file DepoChunker.cxx.

{
    out.push_back(std::make_shared<SimpleDepoSet>(m_count, m_depos));
    m_depos.clear();
    ++m_count;
}

bool Gen::DepoChunker::operator() ( const input_pointer &  in, output_queue &  outq  )

virtual

The calling signature:

Implements WireCell::IQueuedoutNode< IDepo, IDepoSet >.

Definition at line 47 of file DepoChunker.cxx.

{
    if (!depo) {                // EOS
        emit(deposetqueue);
        m_depos.push_back(depo);
        m_gate = m_starting_gate;
        return true;
    }
            
    const double now = depo->time();

    // inside current gate.
    if (m_gate.first <= now and now < m_gate.second) {
        m_depos.push_back(depo);
        return true;
    }

    if (now >= m_gate.second) {   // start new gate
        emit(deposetqueue);
        const double window = m_gate.second - m_gate.first;
        m_gate = std::pair<double,double>(m_gate.second, m_gate.second + window);
        m_depos.push_back(depo);
        return true;
    }

    std::cerr << "Gen::DepoChunker: out of time order depo received: now=" << now/units::s << "s\n";
    return false;
}

Member Data Documentation

int WireCell::Gen::DepoChunker::m_count

private

Definition at line 40 of file DepoChunker.h.

IDepo::vector WireCell::Gen::DepoChunker::m_depos

private

Definition at line 46 of file DepoChunker.h.

std::pair<double,double> WireCell::Gen::DepoChunker::m_gate

private

Definition at line 43 of file DepoChunker.h.

std::pair<double,double> WireCell::Gen::DepoChunker::m_starting_gate

private

Definition at line 43 of file DepoChunker.h.

---

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

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