WireCell::SigProc::Omnibus Class Reference

#include <Omnibus.h>

Inheritance diagram for WireCell::SigProc::Omnibus:

Public Member Functions
	Omnibus ()
virtual	~Omnibus ()
virtual void	execute ()
	Implement to run something. 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::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
std::string	m_input_tn
std::string	m_output_tn
std::vector< std::string >	m_filters_tn
IFrameSource::pointer	m_input
std::vector< IFrameFilter::pointer >	m_filters
IFrameSink::pointer	m_output

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 20 of file Omnibus.h.

Constructor & Destructor Documentation

SigProc::Omnibus::Omnibus

(

)

Definition at line 17 of file Omnibus.cxx.

{
}

SigProc::Omnibus::~Omnibus ( )

virtual

Definition at line 21 of file Omnibus.cxx.

{
}

Member Function Documentation

void SigProc::Omnibus::configure ( const WireCell::Configuration &  config )

virtual

Accept a configuration.

Implements WireCell::IConfigurable.

Definition at line 35 of file Omnibus.cxx.

{
    m_input_tn = cfg["source"].asString(); // keep for printouts later
    m_input = Factory::find_tn<IFrameSource>(m_input_tn);

    m_output_tn = cfg["sink"].asString(); // keep for printouts later
    if (m_output_tn.empty()) {
        std::cerr << "Omnibus has no final frame sink component.\n";
        m_output = nullptr;
    }
    else {
        m_output = Factory::find_tn<IFrameSink>(m_output_tn);
    }

    m_filters.clear();
    auto jffl = cfg["filters"];
    for (auto jff : jffl) {
        std::string fftn = jff.asString();
        std::cerr << "Omnibus adding frame filter: \"" << fftn << "\"\n";
        auto ff = Factory::find_tn<IFrameFilter>(fftn);
        m_filters.push_back(ff);
        m_filters_tn.push_back(fftn);
    }
}

WireCell::Configuration SigProc::Omnibus::default_configuration ( ) const

virtual

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

Reimplemented from WireCell::IConfigurable.

Definition at line 26 of file Omnibus.cxx.

{
    Configuration cfg;
    cfg["source"] = "";         // required
    cfg["filters"] = Json::arrayValue;
    cfg["sink"] = "";           // optional
    return cfg;
}

void SigProc::Omnibus::execute ( )

virtual

Implement to run something.

Implements WireCell::IApplication.

Definition at line 61 of file Omnibus.cxx.

{
    // ExecMon em("omnibus starts");

    IFrame::pointer frame;
    if (!(*m_input)(frame)) {
        std::cerr << "Omnibus: failed to get input frame from " << m_input_tn << "\n";
        THROW(RuntimeError() << errmsg{"Omnibus: failed to get input frame"});
    }
    if (!frame) {
        std::cerr << "Omnibus: got null frame, forwarding, assuming we have reached EOS\n";
    }
    else {
        if (!frame->traces()->size()) {
            std::cerr << "Omnibus: got empty input frame, something is busted\n";
                    THROW(RuntimeError() << errmsg{"Omnibus: got empty input frame, something is busted"});
        }
        else {
            std::cerr << "Omnibus: got input frame from "<<m_input_tn<<" with " << frame->traces()->size() << " traces\n";
            dump_frame(frame);
        }
    }
    
    //em("sourced frame");

    int count = 0;
    for (auto ff : m_filters) {
        std::string tn = m_filters_tn[count++];
        IFrame::pointer nextframe;
        if (!(*ff)(frame, nextframe)) {
            std::cerr << "Failed to filter frame from "<<tn<<"\n"; // fixme, give more info
            THROW(RuntimeError() << errmsg{"failed to filter frame"});
        }
        if (!nextframe && !frame) {
            continue;           // processing EOS
        }
        if (!nextframe) {
            std::cerr << "Omnibus: filter "<<tn<<" returned a null frame\n";
            THROW(RuntimeError() << errmsg{"filter returned a null frame"});
        }
        //em("filtered frame from " + tn);

        frame = nextframe;
        nextframe = nullptr;
        //em("dropped input to " + tn);

        if (frame) {
            std::cerr << "Omnibus: got frame from "<<tn<<" with " << frame->traces()->size() << " traces\n";
            dump_frame(frame);
        }
    }

    if (m_output) {
        if (!(*m_output)(frame)) {
            std::cerr << "Omnibus: failed to send output frame to "<<m_output_tn<<"\n";
            THROW(RuntimeError() << errmsg{"failed to send output frame"});
        }
    }
    //em("sunk frame");

    frame = nullptr;
    //em("dropped output frame");

    //std::cerr << em.summary() << std::endl;
}

Member Data Documentation

std::vector<IFrameFilter::pointer> WireCell::SigProc::Omnibus::m_filters

private

Definition at line 37 of file Omnibus.h.

std::vector<std::string> WireCell::SigProc::Omnibus::m_filters_tn

private

Definition at line 35 of file Omnibus.h.

IFrameSource::pointer WireCell::SigProc::Omnibus::m_input

private

Definition at line 36 of file Omnibus.h.

std::string WireCell::SigProc::Omnibus::m_input_tn

private

Definition at line 34 of file Omnibus.h.

IFrameSink::pointer WireCell::SigProc::Omnibus::m_output

private

Definition at line 38 of file Omnibus.h.

std::string WireCell::SigProc::Omnibus::m_output_tn

private

Definition at line 34 of file Omnibus.h.

---

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

• wire-cell-build/sigproc/inc/WireCellSigProc/Omnibus.h
• wire-cell-build/sigproc/src/Omnibus.cxx