WireCell::Sio::BeeDepoSource Class Reference

#include <BeeDepoSource.h>

Inheritance diagram for WireCell::Sio::BeeDepoSource:

Public Member Functions
	BeeDepoSource ()
virtual	~BeeDepoSource ()
virtual bool	operator() (IDepo::pointer &out)
	IDepoSource. More...
virtual WireCell::Configuration	default_configuration () const
	IConfigurable. More...
virtual void	configure (const WireCell::Configuration &config)
	Accept a configuration. More...
Public Member Functions inherited from WireCell::IDepoSource
virtual	~IDepoSource ()
virtual std::string	signature ()
	Set the signature for all subclasses. More...
Public Member Functions inherited from WireCell::ISourceNode< IDepo >
virtual	~ISourceNode ()
virtual NodeCategory	category ()
	Return the behavior category type. More...
virtual bool	operator() (boost::any &anyout)
virtual std::vector< std::string >	output_types ()
Public Member Functions inherited from WireCell::ISourceNodeBase
virtual	~ISourceNodeBase ()
Public Member Functions inherited from WireCell::INode
virtual	~INode ()
virtual int	concurrency ()
virtual std::vector< std::string >	input_types ()
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
std::vector< std::string >	m_filenames
std::string	m_policy
IDepo::vector	m_depos

Additional Inherited Members
Public Types inherited from WireCell::IDepoSource
typedef std::shared_ptr< IDepoSource >	pointer
Public Types inherited from WireCell::ISourceNode< IDepo >
typedef IDepo	output_type
typedef ISourceNode< IDepo >	signature_type
typedef std::shared_ptr< signature_type >	pointer
typedef std::shared_ptr< const IDepo >	output_pointer
Public Types inherited from WireCell::ISourceNodeBase
typedef std::shared_ptr< ISourceNodeBase >	pointer
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 38 of file BeeDepoSource.h.

Constructor & Destructor Documentation

Sio::BeeDepoSource::BeeDepoSource

(

)

Definition at line 21 of file BeeDepoSource.cxx.

    : m_policy("")
{
}

Sio::BeeDepoSource::~BeeDepoSource ( )

virtual

Definition at line 26 of file BeeDepoSource.cxx.

{
}

Member Function Documentation

void Sio::BeeDepoSource::configure ( const WireCell::Configuration &  config )

virtual

Accept a configuration.

Implements WireCell::IConfigurable.

Definition at line 86 of file BeeDepoSource.cxx.

{
    m_filenames = get< std::vector<std::string> >(cfg, "filelist");
    std::reverse(m_filenames.begin(), m_filenames.end()); // to use pop_back().
    m_policy = get<std::string>(cfg, "policy", "");
}

WireCell::Configuration Sio::BeeDepoSource::default_configuration ( ) const

virtual

IConfigurable.

Reimplemented from WireCell::IConfigurable.

Definition at line 77 of file BeeDepoSource.cxx.

{
    Configuration cfg;
    cfg["filelist"] = Json::arrayValue; // list of input files, empties are skipped
    cfg["policy"] = ""; // set to "stream" to avoid sending EOS after each file's worth of depos.
    return cfg;
}

bool Sio::BeeDepoSource::operator() ( IDepo::pointer &  out )

virtual

IDepoSource.

Implements WireCell::ISourceNode< IDepo >.

Definition at line 30 of file BeeDepoSource.cxx.

{
    out = nullptr;

    if (m_depos.size() > 0) {
        out = m_depos.back();
        m_depos.pop_back();
        return true;
    }

    // refill
    while (!m_filenames.empty()) {

        std::string fname = m_filenames.back();
        m_filenames.pop_back();
        Json::Value jdat = Persist::load(fname);
        int ndepos = jdat["x"].size();
        if (!ndepos) {
            continue;
        }

        m_depos.resize(ndepos, nullptr);
        for (int idepo=0; idepo < ndepos; ++idepo) {
            m_depos[idepo] = std::make_shared<SimpleDepo>(
                jdat["t"][idepo].asDouble(),
                Point(
                    jdat["x"][idepo].asDouble(),
                    jdat["y"][idepo].asDouble(),
                    jdat["z"][idepo].asDouble()),
                jdat["q"][idepo].asDouble());
        }
        if (m_policy != "stream") {
            m_depos.push_back(nullptr); // chunk by file
        }
        std::reverse(m_depos.begin(), m_depos.end());
        break;
    }

    if (m_depos.empty()) {
        return false;
    }
    
    out = m_depos.back();
    m_depos.pop_back();
    return true;
}

Member Data Documentation

IDepo::vector WireCell::Sio::BeeDepoSource::m_depos

private

Definition at line 56 of file BeeDepoSource.h.

std::vector<std::string> WireCell::Sio::BeeDepoSource::m_filenames

private

Definition at line 54 of file BeeDepoSource.h.

std::string WireCell::Sio::BeeDepoSource::m_policy

private

Definition at line 55 of file BeeDepoSource.h.

---

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

• wire-cell-build/sio/inc/WireCellSio/BeeDepoSource.h
• wire-cell-build/sio/src/BeeDepoSource.cxx