JANA/Topology/JEventMapArrow.h

0001 // Copyright 2024, Jefferson Science Associates, LLC.
0002 // Subject to the terms in the LICENSE file found in the top-level directory.
0003
0004 #pragma once
0005
0006 #include <JANA/Topology/JArrow.h>
0007
0008 class JEventPool;
0009 class JEventSource;
0010 class JEventUnfolder;
0011 class JEventProcessor;
0012 class JEvent;
0013
0014
0015 class JEventMapArrow : public JArrow {
0016
0017 public:
0018     enum PortIndex {EVENT_IN=0, EVENT_OUT=1};
0019
0020 private:
0021     std::vector<JEventSource*> m_sources;
0022     std::vector<JEventUnfolder*> m_unfolders;
0023     std::vector<JEventProcessor*> m_procs;
0024
0025 public:
0026     JEventMapArrow(std::string name);
0027
0028     void add_source(JEventSource* source);
0029     void add_unfolder(JEventUnfolder* unfolder);
0030     void add_processor(JEventProcessor* proc);
0031
0032     void fire(JEvent* input, OutputData& outputs, size_t& output_count, JArrow::FireResult& status);
0033
0034     void initialize() final;
0035     void finalize() final;
0036 };
0037