36 selections_(selections),
48 FDEBUG(6) <<
"StreamSerializer::serializeRegistry" << std::endl;
51 FDEBUG(9) <<
"Product List: " << std::endl;
56 FDEBUG(9) <<
"StreamOutput got product = " <<
selection.first->className()
72 int bres = data_buffer.
rootbuf_.WriteObjectAny((
char*)&sd, tc);
77 throw cms::Exception(
"StreamTranslation",
"Registry serialization failed")
78 <<
"StreamSerializer failed to serialize registry\n";
85 throw cms::Exception(
"StreamTranslation",
"Registry serialization truncated")
86 <<
"StreamSerializer module attempted to serialize\n"
87 <<
"a registry that is to big for the allocated buffers\n";
92 throw cms::Exception(
"StreamTranslation",
"Registry serialization failed")
93 <<
"StreamSerializer module got an unknown error code\n"
94 <<
" while attempting to serialize registry\n";
101 data_buffer.
ptr_ = (
unsigned char*)data_buffer.
rootbuf_.Buffer();
135 selectionIDs.push_back(selectorConfig);
162 int bres = data_buffer.
rootbuf_.WriteObjectAny(&se,
tc_);
166 throw cms::Exception(
"StreamTranslation",
"Event serialization failed")
167 <<
"StreamSerializer failed to serialize event: "
175 throw cms::Exception(
"StreamTranslation",
"Event serialization truncated")
176 <<
"StreamSerializer module attempted to serialize an event\n"
177 <<
"that is to big for the allocated buffers: "
183 throw cms::Exception(
"StreamTranslation",
"Event serialization failed")
184 <<
"StreamSerializer module got an unknown error code\n"
185 <<
" while attempting to serialize event: "
193 data_buffer.
ptr_ = (
unsigned char*)data_buffer.
rootbuf_.Buffer();
195 if(data_buffer.
ptr_ != data_.ptr_) {
196 std::cerr <<
"ROOT reset the buffer!!!!\n";
197 data_.ptr_ = data_buffer.
ptr_;
207 if(use_compression) {
208 unsigned int dest_size =
229 unsigned int inputSize,
230 std::vector<unsigned char> &outputBuffer,
231 int compressionLevel) {
232 unsigned int resultSize = 0;
235 unsigned long dest_size = (
unsigned long)(
double(inputSize)*
237 if(outputBuffer.size() < dest_size) outputBuffer.resize(dest_size);
240 int ret = compress2(&outputBuffer[0], &dest_size, inputBuffer,
241 inputSize, compressionLevel);
246 resultSize = dest_size;
248 FDEBUG(1) <<
" original size = " << inputSize
249 <<
" final size = " << dest_size
250 <<
" ratio = " << double(dest_size)/double(inputSize)
254 FDEBUG(9) <<
"Compression Return value: " << ret
255 <<
" Okay = " << Z_OK << std::endl;
257 std::cerr <<
"Compression Return value: " << ret <<
" Okay = " << Z_OK << std::endl;
tuple ret
prodAgent to be discontinued
std::vector< BranchIDList > BranchIDLists
EventAuxiliary const & eventAuxiliary() const
edm::propagate_const< TClass * > tc_
ProductProvenance const * productProvenance() const
edm::propagate_const< unsigned char * > ptr_
TClass * getTClass(const std::type_info &ti)
static unsigned int compressBuffer(unsigned char *inputBuffer, unsigned int inputSize, std::vector< unsigned char > &outputBuffer, int compressionLevel)
std::vector< EventSelectionID > EventSelectionIDVector
std::vector< std::pair< BranchDescription const *, EDGetToken > > SelectedProducts
std::vector< BranchID > const & parents() const
std::vector< unsigned char > comp_buf_
Provenance const * provenance() const
unsigned int curr_event_size_
bool getMapped(key_type const &k, value_type &result) const
TypeID unwrappedTypeID() const
WrapperBase const * wrapper() const
unsigned char const * bufferPointer() const
int serializeRegistry(SerializeDataBuffer &data_buffer, const BranchIDLists &branchIDLists, ThinnedAssociationsHelper const &thinnedAssociationsHelper)
How EventSelector::AcceptEvent() decides whether to accept an event for output otherwise it is excluding the probing of A single or multiple positive and the trigger will pass if any such matching triggers are PASS or EXCEPTION[A criterion thatmatches no triggers at all is detected and causes a throw.] A single negative with an expectation of appropriate bit checking in the decision and the trigger will pass if any such matching triggers are FAIL or EXCEPTION A wildcarded negative criterion that matches more than one trigger in the trigger but the state exists so we define the behavior If all triggers are the negative crieriion will lead to accepting the event(this again matches the behavior of"!*"before the partial wildcard feature was incorporated).The per-event"cost"of each negative criterion with multiple relevant triggers is about the same as!*was in the past
unsigned int curr_space_used_
void Adler32(char const *data, size_t len, uint32_t &a, uint32_t &b)
SelectedProducts const * selections_
ParentageID const & parentageID() const
int serializeEvent(EventForOutput const &event, ParameterSetID const &selectorConfig, bool use_compression, int compression_level, SerializeDataBuffer &data_buffer)
static ParentageRegistry * instance()
void fillMap(regmap_type &fillme) const
static Registry * instance()
StreamSerializer(SelectedProducts const *selections)