JANA/Topology/JEventSourceArrow.h

0001
0002 // Copyright 2020, Jefferson Science Associates, LLC.
0003 // Subject to the terms in the LICENSE file found in the top-level directory.
0004
0005 #pragma once
0006 #include <JANA/Topology/JPipelineArrow.h>
0007
0008 using Event = std::shared_ptr<JEvent>;
0009 using EventQueue = JMailbox<Event*>;
0010 class JEventPool;
0011
0012 class JEventSourceArrow : public JPipelineArrow<JEventSourceArrow, Event> {
0013 private:
0014     std::vector<JEventSource*> m_sources;
0015     size_t m_current_source = 0;
0016
0017 public:
0018     JEventSourceArrow(std::string name, std::vector<JEventSource*> sources, EventQueue* output_queue, JEventPool* pool);
0019     void initialize() final;
0020     void finalize() final;
0021
0022     void process(Event* event, bool& success, JArrowMetrics::Status& status);
0023 };
0024