|
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
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
|
#ifndef Streamer_StreamedProducts_h
#define Streamer_StreamedProducts_h
/*
Simple packaging of all the event data that is needed to be serialized
for transfer.
The "other stuff in the SendEvent still needs to be
populated.
The product is paired with its provenance, and the entire event
is captured in the SendEvent structure.
*/
#include <vector>
#include "DataFormats/Provenance/interface/ProductDescription.h"
#include "DataFormats/Provenance/interface/BranchID.h"
#include "DataFormats/Provenance/interface/EventAuxiliary.h"
#include "DataFormats/Provenance/interface/ParameterSetID.h"
#include "DataFormats/Provenance/interface/ParameterSetBlob.h"
#include "DataFormats/Provenance/interface/EventSelectionID.h"
#include "DataFormats/Provenance/interface/BranchListIndex.h"
#include "DataFormats/Provenance/interface/ProcessHistory.h"
#include "DataFormats/Provenance/interface/BranchIDList.h"
#include "DataFormats/Provenance/interface/ThinnedAssociationsHelper.h"
namespace edm {
// ------------------------------------------
class WrapperBase;
class StreamedProduct {
public:
StreamedProduct() : prod_(nullptr), desc_(nullptr), present_(false), parents_(nullptr) {}
explicit StreamedProduct(ProductDescription const& desc)
: prod_(nullptr), desc_(&desc), present_(false), parents_(nullptr) {}
StreamedProduct(WrapperBase const* prod,
ProductDescription const& desc,
bool present,
std::vector<BranchID> const* parents);
ProductDescription const* desc() const { return desc_; }
BranchID branchID() const { return desc_->branchID(); }
bool present() const { return present_; }
std::vector<BranchID> const* parents() const { return parents_; }
WrapperBase const* prod() { return prod_; }
void clear() {
prod_ = nullptr;
delete desc_;
desc_ = nullptr;
present_ = false;
delete parents_;
parents_ = nullptr;
}
private:
WrapperBase const* prod_;
ProductDescription const* desc_;
bool present_;
std::vector<BranchID> const* parents_;
};
// ------------------------------------------
typedef std::vector<StreamedProduct> SendProds;
// ------------------------------------------
// Contains either Event data or meta data about an Event. The header of the
// message contains which way an instance of this class is to be interpreted
// via the use of EventMsgView::isEventMetaData()
class SendEvent {
public:
SendEvent() {}
SendEvent(EventAuxiliary const& aux,
ProcessHistory const& processHistory,
EventSelectionIDVector const& eventSelectionIDs,
BranchListIndexes const& branchListIndexes,
BranchIDLists const& branchIDLists,
ThinnedAssociationsHelper const& thinnedAssociationsHelper,
uint32_t metaDataChecksum)
: aux_(aux),
processHistory_(processHistory),
eventSelectionIDs_(eventSelectionIDs),
branchListIndexes_(branchListIndexes),
branchIDLists_(branchIDLists),
thinnedAssociationsHelper_(thinnedAssociationsHelper),
products_(),
metaDataChecksum_(metaDataChecksum) {}
EventAuxiliary const& aux() const { return aux_; }
SendProds const& products() const { return products_; }
ProcessHistory const& processHistory() const { return processHistory_; }
EventSelectionIDVector const& eventSelectionIDs() const { return eventSelectionIDs_; }
BranchListIndexes const& branchListIndexes() const { return branchListIndexes_; }
//This will only hold values for EventMetaData messages
BranchIDLists const& branchIDLists() const { return branchIDLists_; }
//This will only hold values for EventMetaData messages
ThinnedAssociationsHelper const& thinnedAssociationsHelper() const { return thinnedAssociationsHelper_; }
//This is the adler32 checksum of the EventMetaData associated with this Event
uint32_t metaDataChecksum() const { return metaDataChecksum_; }
SendProds& products() { return products_; }
private:
EventAuxiliary aux_;
ProcessHistory processHistory_;
EventSelectionIDVector eventSelectionIDs_;
BranchListIndexes branchListIndexes_;
BranchIDLists branchIDLists_;
ThinnedAssociationsHelper thinnedAssociationsHelper_;
SendProds products_;
uint32_t metaDataChecksum_;
// other tables necessary for provenance lookup
};
typedef std::vector<ProductDescription> SendDescs;
class SendJobHeader {
public:
typedef std::map<ParameterSetID, ParameterSetBlob> ParameterSetMap;
SendJobHeader() {}
SendDescs const& descs() const { return descs_; }
ParameterSetMap const& processParameterSet() const { return processParameterSet_; }
void push_back(ProductDescription const& bd) { descs_.push_back(bd); }
void setParameterSetMap(ParameterSetMap const& psetMap) { processParameterSet_ = psetMap; }
void initializeTransients();
private:
SendDescs descs_;
ParameterSetMap processParameterSet_;
};
} // namespace edm
#endif
|