|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
|
#ifndef EventFilter_Utilities_DAQSourceModels_h
#define EventFilter_Utilities_DAQSourceModels_h
/*
* Base class defining modular interface for DAQSource data models
* See doc/README-DTH.md for interface description
*/
#include <condition_variable>
#include <cstdio>
#include <filesystem>
#include <memory>
#include <mutex>
#include <thread>
#include "tbb/concurrent_queue.h"
#include "tbb/concurrent_vector.h"
#include "DataFormats/Provenance/interface/ProcessHistoryID.h"
#include "DataFormats/Provenance/interface/Timestamp.h"
#include "EventFilter/Utilities/interface/EvFDaqDirector.h"
#include "FWCore/Sources/interface/RawInputSource.h"
#include "FWCore/Framework/interface/EventPrincipal.h"
#include "FWCore/Sources/interface/DaqProvenanceHelper.h"
#include "FWCore/ServiceRegistry/interface/Service.h"
#include "IOPool/Streamer/interface/FRDEventMessage.h"
#include "DataFormats/FEDRawData/interface/FEDNumbering.h"
#include "DataFormats/Provenance/interface/LuminosityBlockAuxiliary.h"
//import InputChunk
#include "EventFilter/Utilities/interface/SourceRawFile.h"
class RawInputFile;
class UnpackedRawEventWrapper;
class DAQSource;
//evf?
class DataMode {
public:
DataMode(DAQSource* daqSource) : daqSource_(daqSource) {}
virtual ~DataMode() = default;
virtual std::vector<std::shared_ptr<const edm::DaqProvenanceHelper>>& makeDaqProvenanceHelpers() = 0;
virtual void readEvent(edm::EventPrincipal& eventPrincipal) = 0;
virtual int dataVersion() const = 0;
virtual void detectVersion(unsigned char* fileBuf, uint32_t fileHeaderOffset) = 0;
virtual uint32_t headerSize() const = 0;
virtual bool versionCheck() const = 0;
virtual uint64_t dataBlockSize() const = 0;
virtual void makeDataBlockView(unsigned char* addr, RawInputFile* rawFile) = 0;
virtual bool nextEventView(RawInputFile*) = 0;
virtual bool blockChecksumValid() = 0;
virtual bool checksumValid() = 0;
virtual std::string getChecksumError() const = 0;
virtual uint32_t run() const = 0;
virtual bool dataBlockCompleted() const = 0;
virtual bool requireHeader() const = 0;
virtual bool fitToBuffer() const = 0;
virtual void unpackFile(RawInputFile* file) = 0;
virtual bool dataBlockInitialized() const = 0;
virtual void setDataBlockInitialized(bool) = 0;
virtual void setTCDSSearchRange(uint16_t, uint16_t) = 0;
virtual std::pair<bool, std::vector<std::string>> defineAdditionalFiles(std::string const& primaryName,
bool fileListMode) const = 0;
virtual bool isMultiDir() const { return false; }
virtual void makeDirectoryEntries(std::vector<std::string> const& baseDirs,
std::vector<int> const& numSources,
std::vector<int> const& sourceIDs,
std::string const& sourceIdentifier,
std::string const& runDir) = 0;
void setTesting(bool testing) { testing_ = testing; }
bool errorDetected() { return errorDetected_; }
//pre-parse file to count events
virtual bool hasEventCounterCallback() const { return false; }
virtual int eventCounterCallback(std::string const& name, int& fd, int64_t& fsize, uint32_t sLS, bool& found) const {
return -1;
}
protected:
DAQSource* daqSource_;
bool testing_ = false;
bool errorDetected_ = false;
};
#endif // EventFilter_Utilities_DAQSourceModels_h
|