JANA/Topology/JMapArrow.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 JMapArrow : 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     JMapArrow(std::string name, JEventLevel level);
0027
0028     void AddSource(JEventSource* source);
0029     void AddUnfolder(JEventUnfolder* unfolder);
0030     void AddProcessor(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