Public Types | Public Member Functions | Private Attributes | List of all members
WireCell::QueuedNodeProc Class Reference

#include <GenPipeline.h>

Inheritance diagram for WireCell::QueuedNodeProc:
WireCell::FilterProc WireCell::SourceProc WireCell::SinkProc WireCell::Proc WireCell::Proc

Public Types

typedef WireCell::IQueuedoutNodeBase node_t
 
typedef std::shared_ptr< node_tnode_pointer_t
 

Public Member Functions

 QueuedNodeProc (node_pointer_t node)
 
virtual ~QueuedNodeProc ()
 
virtual Pipeinput_pipe ()
 
virtual Pipeoutput_pipe ()
 
virtual bool operator() ()
 
- Public Member Functions inherited from WireCell::FilterProc
virtual ~FilterProc ()
 
- Public Member Functions inherited from WireCell::SourceProc
virtual ~SourceProc ()
 
- Public Member Functions inherited from WireCell::Proc
virtual ~Proc ()
 
- Public Member Functions inherited from WireCell::SinkProc
virtual ~SinkProc ()
 

Private Attributes

Pipe iq
 
Pipe oq
 
node_pointer_t node
 

Detailed Description

Definition at line 186 of file GenPipeline.h.

Member Typedef Documentation

Definition at line 189 of file GenPipeline.h.

Definition at line 188 of file GenPipeline.h.

Constructor & Destructor Documentation

WireCell::QueuedNodeProc::QueuedNodeProc ( node_pointer_t  node)
inline

Definition at line 191 of file GenPipeline.h.

191 : node(node) {}
virtual WireCell::QueuedNodeProc::~QueuedNodeProc ( )
inlinevirtual

Definition at line 192 of file GenPipeline.h.

192 {}

Member Function Documentation

virtual Pipe& WireCell::QueuedNodeProc::input_pipe ( )
inlinevirtual

Implements WireCell::SinkProc.

Definition at line 194 of file GenPipeline.h.

194  {
195  return iq;
196  }
virtual bool WireCell::QueuedNodeProc::operator() ( void  )
inlinevirtual

Implements WireCell::Proc.

Definition at line 201 of file GenPipeline.h.

201  {
202  if (iq.empty()) { return false; }
203  queuedany anyq;
204  bool ok = (*node)(iq.front(), anyq);
205  if (!ok) return false;
206  iq.pop();
207  for (auto anyo : anyq) {
208  oq.push(anyo);
209  }
210  return true;
211  }
std::deque< boost::any > queuedany
Definition: GenPipeline.h:181
virtual Pipe& WireCell::QueuedNodeProc::output_pipe ( )
inlinevirtual

Implements WireCell::SourceProc.

Definition at line 197 of file GenPipeline.h.

197  {
198  return oq;
199  }

Member Data Documentation

Pipe WireCell::QueuedNodeProc::iq
private

Definition at line 214 of file GenPipeline.h.

node_pointer_t WireCell::QueuedNodeProc::node
private

Definition at line 215 of file GenPipeline.h.

Pipe WireCell::QueuedNodeProc::oq
private

Definition at line 214 of file GenPipeline.h.


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