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/JPipelineArrow.h>
0007
0008 class JEventPool;
0009 class JEventSource;
0010 class JEventUnfolder;
0011 class JEventProcessor;
0012 class JEvent;
0013
0014 using Event = std::shared_ptr<JEvent>;
0015 using EventQueue = JMailbox<Event*>;
0016
0017 class JEventMapArrow : public JPipelineArrow<JEventMapArrow, Event> {
0018
0019 private:
0020     std::vector<JEventSource*> m_sources;
0021     std::vector<JEventUnfolder*> m_unfolders;
0022     std::vector<JEventProcessor*> m_procs;
0023
0024 public:
0025     JEventMapArrow(std::string name, EventQueue *input_queue, EventQueue *output_queue);
0026
0027     void add_source(JEventSource* source);
0028     void add_unfolder(JEventUnfolder* unfolder);
0029     void add_processor(JEventProcessor* proc);
0030
0031     void process(Event* event, bool& success, JArrowMetrics::Status& status);
0032
0033     void initialize() final;
0034     void finalize() final;
0035 };
0036