#include <ChannelSplitter.h>

Inheritance diagram for WireCell::SigProc::ChannelSplitter:

Public Member Functions
	ChannelSplitter (size_t multiplicity=0)

virtual	~ChannelSplitter ()

virtual std::vector< std::string >	output_types ()

virtual bool	operator() (const input_pointer &in, output_vector &outv)

virtual void	configure (const WireCell::Configuration &cfg)
	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::IFrameFanout
virtual	~IFrameFanout ()

virtual std::string	signature ()

Public Member Functions inherited from WireCell::IFanoutNode< IFrame, IFrame, 0 >
virtual	~IFanoutNode ()

virtual bool	operator() (const boost::any &anyin, any_vector &anyv)
	The calling signature: More...

virtual std::vector< std::string >	input_types ()

Public Member Functions inherited from WireCell::IFanoutNodeBase
virtual	~IFanoutNodeBase ()

virtual NodeCategory	category ()
	Return the behavior category type. More...

virtual int	concurrency ()
	Fanout nodes can usually 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
std::unordered_map< int, int >	m_c2p

std::vector< std::string >	m_tags

size_t	m_multiplicity

tagrules::Context	m_ft

Log::logptr_t	log

Additional Inherited Members
Public Types inherited from WireCell::IFanoutNode< IFrame, IFrame, 0 >
typedef IFrame	input_type

typedef IFrame	output_type

typedef std::shared_ptr< const IFrame >	input_pointer

typedef std::shared_ptr< const IFrame >	output_pointer

typedef std::vector< output_pointer >	output_vector

Public Types inherited from WireCell::IFanoutNodeBase
typedef std::shared_ptr< IFanoutNodeBase >	pointer

typedef std::vector< boost::any >	any_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 21 of file ChannelSplitter.h.

Constructor & Destructor Documentation

SigProc::ChannelSplitter::ChannelSplitter ( size_t multiplicity = 0 )

Definition at line 14 of file ChannelSplitter.cxx.

     : m_multiplicity(multiplicity)
     , log(Log::logger("glue"))
 {
 }

SigProc::ChannelSplitter::~ChannelSplitter ( )

virtual

Definition at line 19 of file ChannelSplitter.cxx.

20 {

21 }

Member Function Documentation

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

virtual

Accept a configuration.

Implements WireCell::IConfigurable.

Definition at line 38 of file ChannelSplitter.cxx.

 {
     m_multiplicity = 0;
     m_c2p.clear();
     for (auto janode : cfg["anodes"]) {
         auto anode = Factory::find_tn<IAnodePlane>(janode.asString());
         for (auto c : anode->channels()) {
             m_c2p[c] = m_multiplicity;
         }
         ++m_multiplicity;
     }
     if (m_c2p.empty()) {
         THROW(ValueError() << errmsg{"ChannelSplitter must have at least one annode"});
     }
     m_ft.configure(cfg["tag_rules"]);
 }

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

virtual

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

Reimplemented from WireCell::IConfigurable.

Definition at line 23 of file ChannelSplitter.cxx.

 {
     Configuration cfg;
 
     // A list of anode names
     cfg["anodes"] = Json::arrayValue;
     // Tag rules are an array, one element per output port.  Each
     // element is an object keyed with "frame" or "trace".  Each of
     // their values are an object keyed by a regular expression
     // (regex) and with values that are a single tag or an array of
     // tags.  See util/test_tagrules for examples.
     cfg["tag_rules"] = Json::arrayValue;
 
     return cfg;
 }

bool SigProc::ChannelSplitter::operator()	(	const input_pointer &	in,
		output_vector &	outv
	)

virtual

Implements WireCell::IFanoutNode< IFrame, IFrame, 0 >.

Definition at line 64 of file ChannelSplitter.cxx.

 {
     outv.resize(m_multiplicity);
 
     if (!in) {                  //  pass on EOS
         for (size_t ind=0; ind < m_multiplicity; ++ind) {
             outv[ind] = in;
         }
         log->debug("ChannelSplitter: see EOS");
         return true;
     }
 
     std::vector<ITrace::vector> port_traces(m_multiplicity);
     
     for (const auto& itrace : *(in->traces())) {
         int chan = itrace->channel();
         const auto& it = m_c2p.find(chan);
         if (it == m_c2p.end()) {
             log->debug("ChannelSplitter: no port for channel {}, dropping", chan);
             continue;
         }
         const int port = it->second;
         port_traces[port].push_back(itrace);
     }
 
     auto fintags = in->frame_tags();
     std::stringstream taginfo;
     for (size_t iport=0; iport<m_multiplicity; ++iport) {
 
         // Basic frame stays the same.
         auto sfout = new SimpleFrame(in->ident(), in->time(), port_traces[iport], in->tick());
 
         // Transform any frame tags based on a per output port ruleset
         auto fouttags = m_ft.transform(iport, "frame", fintags);
 
         for (auto ftag : fouttags) {
             sfout->tag_frame(ftag);
             taginfo << " ftag:" << ftag;
         }
 
         for (auto inttag : in->trace_tags()) {
             tagrules::tagset_t touttags = m_ft.transform(iport, "trace", inttag);
             if (touttags.empty()) {
                 continue;
             }
             const auto& traces = in->tagged_traces(inttag);
             const auto& summary = in->trace_summary(inttag);
             for (auto otag : touttags) {
                 sfout->tag_traces(otag, traces, summary);
                 taginfo << " " << inttag << "->" << otag;
             }
         };
 
         outv[iport] = IFrame::pointer(sfout);
     }
 
     std::string tagmsg = taginfo.str();
     if (!tagmsg.empty()) {
         log->debug("ChannelSplitter: tagnifo:{}", taginfo.str());
     }
     return true;
 }

std::vector< std::string > SigProc::ChannelSplitter::output_types ( )

virtual

Implements WireCell::IFrameFanout.

Definition at line 56 of file ChannelSplitter.cxx.

 {
     const std::string tname = std::string(typeid(output_type).name());
     std::vector<std::string> ret(m_multiplicity, tname);
     return ret;
 }

Member Data Documentation

Log::logptr_t WireCell::SigProc::ChannelSplitter::log

private

Definition at line 42 of file ChannelSplitter.h.

std::unordered_map<int, int> WireCell::SigProc::ChannelSplitter::m_c2p

private

Definition at line 38 of file ChannelSplitter.h.

tagrules::Context WireCell::SigProc::ChannelSplitter::m_ft

private

Definition at line 41 of file ChannelSplitter.h.

size_t WireCell::SigProc::ChannelSplitter::m_multiplicity

private

Definition at line 40 of file ChannelSplitter.h.

std::vector<std::string> WireCell::SigProc::ChannelSplitter::m_tags

private

Definition at line 39 of file ChannelSplitter.h.

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

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

Public Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation