CMS 3D CMS Logo

List of all members | Public Member Functions | Private Member Functions | Private Attributes
edm::ThinnedAssociationsHelper Class Reference

#include <ThinnedAssociationsHelper.h>

Public Member Functions

void addAssociation (BranchID const &, BranchID const &, BranchID const &)
 
void addAssociation (ThinnedAssociationBranches const &)
 
std::vector< std::pair< BranchID, ThinnedAssociationBranches const * > > associationToBranches () const
 
std::vector< ThinnedAssociationBranches >::const_iterator begin () const
 
void clear ()
 
std::vector< ThinnedAssociationBranches > const & data () const
 
std::vector< ThinnedAssociationBranches >::const_iterator end () const
 
void initAssociationsFromSecondary (std::vector< BranchID > const &, ThinnedAssociationsHelper const &)
 
std::vector< ThinnedAssociationBranches >::const_iterator parentBegin (BranchID const &) const
 
std::vector< ThinnedAssociationBranches >::const_iterator parentEnd (BranchID const &) const
 
void requireMatch (ThinnedAssociationBranches const &input) const
 
void selectAssociationProducts (std::vector< BranchDescription const * > const &associationDescriptions, std::set< BranchID > const &keptProductsInEvent, std::map< BranchID, bool > &keepAssociation) const
 
void sort ()
 
 ThinnedAssociationsHelper ()
 
void updateFromParentProcess (ThinnedAssociationsHelper const &parentThinnedAssociationsHelper, std::map< BranchID, bool > const &keepAssociation, std::map< BranchID::value_type, BranchID::value_type > const &droppedBranchIDToKeptBranchID)
 
void updateFromPrimaryInput (ThinnedAssociationsHelper const &)
 
void updateFromSecondaryInput (ThinnedAssociationsHelper const &, std::vector< BranchID > const &associationsFromSecondary)
 

Private Member Functions

bool shouldKeepAssociation (BranchID const &association, std::vector< std::pair< BranchID, ThinnedAssociationBranches const * > > const &associationToBranches, std::set< BranchID > &branchesInRecursion, std::set< BranchID > const &keptProductsInEvent, std::map< BranchID, bool > &keepAssociation) const
 

Private Attributes

std::vector< ThinnedAssociationBranchesvThinnedAssociationBranches_
 

Detailed Description

Author
W. David Dagenhart, created 11 June 2014

Definition at line 35 of file ThinnedAssociationsHelper.h.

Constructor & Destructor Documentation

edm::ThinnedAssociationsHelper::ThinnedAssociationsHelper ( )

Definition at line 18 of file ThinnedAssociationsHelper.cc.

18  {
19  }

Member Function Documentation

void edm::ThinnedAssociationsHelper::addAssociation ( BranchID const &  parent,
BranchID const &  association,
BranchID const &  thinned 
)
void edm::ThinnedAssociationsHelper::addAssociation ( ThinnedAssociationBranches const &  branches)

Definition at line 62 of file ThinnedAssociationsHelper.cc.

62  {
63  vThinnedAssociationBranches_.push_back(branches);
64  }
std::vector< ThinnedAssociationBranches > vThinnedAssociationBranches_
std::vector< std::pair< BranchID, ThinnedAssociationBranches const * > > edm::ThinnedAssociationsHelper::associationToBranches ( ) const

Definition at line 67 of file ThinnedAssociationsHelper.cc.

References selectAssociationProducts(), and groupFilesInBlocks::temp.

Referenced by initAssociationsFromSecondary(), and updateFromSecondaryInput().

67  {
68  std::vector<std::pair<BranchID, ThinnedAssociationBranches const*> > temp;
69  for(auto const& item : vThinnedAssociationBranches_) {
70  temp.push_back(std::make_pair(item.association(), &item));
71  }
72  std::sort(temp.begin(), temp.end(), [](std::pair<BranchID, ThinnedAssociationBranches const*> const& x,
73  std::pair<BranchID, ThinnedAssociationBranches const*> const& y)
74  { return x.first < y.first; });
75  return temp;
76  }
std::vector< ThinnedAssociationBranches > vThinnedAssociationBranches_
std::vector< ThinnedAssociationBranches >::const_iterator edm::ThinnedAssociationsHelper::begin ( void  ) const

Definition at line 22 of file ThinnedAssociationsHelper.cc.

22  {
23  return vThinnedAssociationBranches_.begin();
24  }
std::vector< ThinnedAssociationBranches > vThinnedAssociationBranches_
void edm::ThinnedAssociationsHelper::clear ( void  )
inline
std::vector<ThinnedAssociationBranches> const& edm::ThinnedAssociationsHelper::data ( ) const
inline

Definition at line 58 of file ThinnedAssociationsHelper.h.

References edm::ThinnedAssociationBranches::association(), and input.

Referenced by updateFromParentProcess(), and updateFromPrimaryInput().

std::vector< ThinnedAssociationBranches > vThinnedAssociationBranches_
std::vector< ThinnedAssociationBranches >::const_iterator edm::ThinnedAssociationsHelper::end ( void  ) const

Definition at line 27 of file ThinnedAssociationsHelper.cc.

Referenced by Types.LuminosityBlockRange::cppID(), and Types.EventRange::cppID().

27  {
28  return vThinnedAssociationBranches_.end();
29  }
std::vector< ThinnedAssociationBranches > vThinnedAssociationBranches_
void edm::ThinnedAssociationsHelper::initAssociationsFromSecondary ( std::vector< BranchID > const &  associationsFromSecondary,
ThinnedAssociationsHelper const &  fileAssociationsHelper 
)

Definition at line 231 of file ThinnedAssociationsHelper.cc.

References edm::ThinnedAssociationBranches::association(), associationToBranches(), Exception, and edm::errors::LogicError.

232  {
233  if(associationsFromSecondary.empty()) return;
234 
235  std::vector<std::pair<BranchID, ThinnedAssociationBranches const*> > assocToBranches =
236  fileAssociationsHelper.associationToBranches();
237 
238  for(BranchID const& association : associationsFromSecondary) {
239 
240  auto branches = std::lower_bound(assocToBranches.begin(), assocToBranches.end(),
241  std::make_pair(association, static_cast<ThinnedAssociationBranches const*>(nullptr)),
242  [](std::pair<BranchID, ThinnedAssociationBranches const*> const& x,
243  std::pair<BranchID, ThinnedAssociationBranches const*> const& y)
244  { return x.first < y.first; });
245  // This should never happen
246  if(branches == assocToBranches.end() || branches->first != association) {
248  "ThinnedAssociationHelper::initAssociationsFromSecondary could not find branches information, contact Framework developers");
249  }
250  addAssociation(*(branches->second));
251  }
252  sort();
253  }
void addAssociation(BranchID const &, BranchID const &, BranchID const &)
std::vector< ThinnedAssociationBranches >::const_iterator edm::ThinnedAssociationsHelper::parentBegin ( BranchID const &  parent) const

Definition at line 32 of file ThinnedAssociationsHelper.cc.

References edmPickEvents::target.

Referenced by BareRootProductGetter::getThinnedProduct(), fwlite::DataGetterHelper::getThinnedProduct(), BareRootProductGetter::getThinnedProducts(), and fwlite::DataGetterHelper::getThinnedProducts().

32  {
33  ThinnedAssociationBranches target(parent, BranchID(), BranchID());
34  return std::lower_bound(vThinnedAssociationBranches_.begin(), vThinnedAssociationBranches_.end(), target,
35  [](ThinnedAssociationBranches const& x,
36  ThinnedAssociationBranches const& y)
37  { return x.parent() < y.parent(); });
38  }
std::vector< ThinnedAssociationBranches > vThinnedAssociationBranches_
std::vector< ThinnedAssociationBranches >::const_iterator edm::ThinnedAssociationsHelper::parentEnd ( BranchID const &  parent) const

Definition at line 41 of file ThinnedAssociationsHelper.cc.

References edmPickEvents::target.

Referenced by BareRootProductGetter::getThinnedProduct(), fwlite::DataGetterHelper::getThinnedProduct(), BareRootProductGetter::getThinnedProducts(), and fwlite::DataGetterHelper::getThinnedProducts().

41  {
42  ThinnedAssociationBranches target(parent, BranchID(), BranchID());
43  return std::upper_bound(vThinnedAssociationBranches_.begin(), vThinnedAssociationBranches_.end(), target,
44  [](ThinnedAssociationBranches const& x,
45  ThinnedAssociationBranches const& y)
46  { return x.parent() < y.parent(); });
47  }
std::vector< ThinnedAssociationBranches > vThinnedAssociationBranches_
void edm::ThinnedAssociationsHelper::requireMatch ( ThinnedAssociationBranches const &  input) const

Definition at line 158 of file ThinnedAssociationsHelper.cc.

References edm::ThinnedAssociationBranches::association(), mps_splice::entry, Exception, edm::errors::MismatchedInputFiles, edm::ThinnedAssociationBranches::parent(), and edm::ThinnedAssociationBranches::thinned().

158  {
159  bool foundMatch = false;
160  for(auto entry = parentBegin(input.parent()), iEnd = parentEnd(input.parent());
161  entry != iEnd; ++entry) {
162  if(entry->association() == input.association() &&
163  entry->thinned() == input.thinned()) {
164  foundMatch = true;
165  break;
166  }
167  }
168  if(!foundMatch) {
169  throw edm::Exception(errors::MismatchedInputFiles, "ThinnedAssociationHelper::requireMatch, Illegal attempt to merge files with different ThinnedAssociations");
170  }
171  }
static std::string const input
Definition: EdmProvDump.cc:45
std::vector< ThinnedAssociationBranches >::const_iterator parentEnd(BranchID const &) const
std::vector< ThinnedAssociationBranches >::const_iterator parentBegin(BranchID const &) const
void edm::ThinnedAssociationsHelper::selectAssociationProducts ( std::vector< BranchDescription const * > const &  associationDescriptions,
std::set< BranchID > const &  keptProductsInEvent,
std::map< BranchID, bool > &  keepAssociation 
) const

Definition at line 80 of file ThinnedAssociationsHelper.cc.

References edm::ThinnedAssociationBranches::association().

Referenced by associationToBranches(), edm::SubProcess::selectProducts(), edm::OutputModule::selectProducts(), edm::global::OutputModuleBase::selectProducts(), edm::limited::OutputModuleBase::selectProducts(), and edm::one::OutputModuleBase::selectProducts().

82  {
83 
84  keepAssociation.clear();
85  // Copy the elements in vThinnedAssociationBranches_ into a vector sorted on
86  // the association BranchID so we can do searches on that BranchID faster.
87  std::vector<std::pair<BranchID, ThinnedAssociationBranches const*> > assocToBranches =
89 
90  for(auto association : associationDescriptions) {
91  if(association->isAlias()) { // There is no reason to configure an association product with an EDAlias (ignore and drop them if they exist)
92  keepAssociation.insert(std::make_pair(association->branchID(), false));
93  } else {
94  std::set<BranchID> branchesInRecursion;
96  assocToBranches,
97  branchesInRecursion,
98  keptProductsInEvent,
99  keepAssociation);
100  }
101  }
102  }
std::vector< std::pair< BranchID, ThinnedAssociationBranches const * > > associationToBranches() const
bool shouldKeepAssociation(BranchID const &association, std::vector< std::pair< BranchID, ThinnedAssociationBranches const * > > const &associationToBranches, std::set< BranchID > &branchesInRecursion, std::set< BranchID > const &keptProductsInEvent, std::map< BranchID, bool > &keepAssociation) const
bool edm::ThinnedAssociationsHelper::shouldKeepAssociation ( BranchID const &  association,
std::vector< std::pair< BranchID, ThinnedAssociationBranches const * > > const &  associationToBranches,
std::set< BranchID > &  branchesInRecursion,
std::set< BranchID > const &  keptProductsInEvent,
std::map< BranchID, bool > &  keepAssociation 
) const
private

Definition at line 104 of file ThinnedAssociationsHelper.cc.

References edm::ThinnedAssociationBranches::association(), Exception, edm::errors::LogicError, and edm::match().

109  {
110 
111  // If we already decided to keep or drop this one, then
112  // return the same decision.
113  auto decision = keepAssociation.find(association);
114  if(decision != keepAssociation.end()) {
115  return decision->second;
116  }
117 
118  // Be careful not to fall into an infinite loop because
119  // of a circular recursion.
120  if(!branchesInRecursion.insert(association).second) {
121  return false;
122  }
123 
124  // If the thinned collection is being kept then keep the association
125  auto branches = std::lower_bound(associationToBranches.begin(), associationToBranches.end(),
126  std::make_pair(association, static_cast<ThinnedAssociationBranches const*>(nullptr)),
127  [](std::pair<BranchID, ThinnedAssociationBranches const*> const& x,
128  std::pair<BranchID, ThinnedAssociationBranches const*> const& y)
129  { return x.first < y.first; });
130  // This should never happen
131  if(branches == associationToBranches.end() || branches->first != association) {
132  throw edm::Exception(errors::LogicError, "ThinnedAssociationHelper::shouldKeepAssociation could not find branches information, contact Framework developers");
133  }
134  BranchID const& thinnedCollection = branches->second->thinned();
135  if(keptProductsInEvent.find(thinnedCollection) != keptProductsInEvent.end()) {
136  keepAssociation.insert(std::make_pair(association , true));
137  return true;
138  }
139  // otherwise loop over any associations where the thinned collection
140  // is also a parent collection and recursively examine those to see
141  // if their thinned collections are being kept.
142  auto iterEnd = parentEnd(thinnedCollection);
143  for(auto match = parentBegin(thinnedCollection); match != iterEnd; ++match) {
144  if(shouldKeepAssociation(match->association(),
146  branchesInRecursion,
147  keptProductsInEvent,
148  keepAssociation)) {
149  keepAssociation.insert(std::make_pair(association , true));
150  return true;
151  }
152  }
153  // drop the association
154  keepAssociation.insert(std::make_pair(association , false));
155  return false;
156  }
std::vector< std::pair< BranchID, ThinnedAssociationBranches const * > > associationToBranches() const
std::vector< ThinnedAssociationBranches >::const_iterator parentEnd(BranchID const &) const
std::vector< ThinnedAssociationBranches >::const_iterator parentBegin(BranchID const &) const
bool shouldKeepAssociation(BranchID const &association, std::vector< std::pair< BranchID, ThinnedAssociationBranches const * > > const &associationToBranches, std::set< BranchID > &branchesInRecursion, std::set< BranchID > const &keptProductsInEvent, std::map< BranchID, bool > &keepAssociation) const
std::string match(BranchDescription const &a, BranchDescription const &b, std::string const &fileName)
void edm::ThinnedAssociationsHelper::sort ( )

Definition at line 49 of file ThinnedAssociationsHelper.cc.

References edm::ThinnedAssociationBranches::association(), and edm::ThinnedAssociationBranches::parent().

49  {
51  [](ThinnedAssociationBranches const& x,
52  ThinnedAssociationBranches const& y)
53  { return x.parent() < y.parent() ? true : y.parent() < x.parent() ? false : x.association() < y.association(); });
54  }
std::vector< ThinnedAssociationBranches > vThinnedAssociationBranches_
void edm::ThinnedAssociationsHelper::updateFromParentProcess ( ThinnedAssociationsHelper const &  parentThinnedAssociationsHelper,
std::map< BranchID, bool > const &  keepAssociation,
std::map< BranchID::value_type, BranchID::value_type > const &  droppedBranchIDToKeptBranchID 
)

Definition at line 207 of file ThinnedAssociationsHelper.cc.

References hitfit::clear(), data(), edm::BranchID::id(), keep, edm::ThinnedAssociationBranches::parent(), and edm::ThinnedAssociationBranches::thinned().

209  {
210  clear();
211  for(auto const& associationBranches : parentThinnedAssociationsHelper.data()) {
212  auto keep = keepAssociation.find(associationBranches.association());
213  if(keep != keepAssociation.end() && keep->second) {
214  BranchID parent = associationBranches.parent();
215  auto iter = droppedBranchIDToKeptBranchID.find(parent.id());
216  if(iter != droppedBranchIDToKeptBranchID.end()) {
217  parent = BranchID(iter->second);
218  }
219  BranchID thinned = associationBranches.thinned();
220  iter = droppedBranchIDToKeptBranchID.find(thinned.id());
221  if(iter != droppedBranchIDToKeptBranchID.end()) {
222  thinned = BranchID(iter->second);
223  }
224  addAssociation(parent, associationBranches.association(), thinned);
225  }
226  }
227  sort();
228  }
void addAssociation(BranchID const &, BranchID const &, BranchID const &)
const int keep
void edm::ThinnedAssociationsHelper::updateFromPrimaryInput ( ThinnedAssociationsHelper const &  helper)

Definition at line 173 of file ThinnedAssociationsHelper.cc.

References data(), and idDealer::inputData.

Referenced by edm::StreamerInputSource::mergeIntoRegistry().

173  {
174  if(vThinnedAssociationBranches_.empty()) {
176  return;
177  }
178  std::vector<ThinnedAssociationBranches> const& inputData = helper.data();
179  for (auto const& inputEntry : inputData) {
180  requireMatch(inputEntry);
181  }
182  }
Definition: helper.py:1
void requireMatch(ThinnedAssociationBranches const &input) const
std::vector< ThinnedAssociationBranches > vThinnedAssociationBranches_
void edm::ThinnedAssociationsHelper::updateFromSecondaryInput ( ThinnedAssociationsHelper const &  helper,
std::vector< BranchID > const &  associationsFromSecondary 
)

Definition at line 184 of file ThinnedAssociationsHelper.cc.

References edm::ThinnedAssociationBranches::association(), associationToBranches(), Exception, and edm::errors::LogicError.

185  {
186  if(associationsFromSecondary.empty()) return;
187 
188  std::vector<std::pair<BranchID, ThinnedAssociationBranches const*> > assocToBranches = helper.associationToBranches();
189 
190  for(BranchID const& association : associationsFromSecondary) {
191 
192  auto branches = std::lower_bound(assocToBranches.begin(), assocToBranches.end(),
193  std::make_pair(association, static_cast<ThinnedAssociationBranches const*>(nullptr)),
194  [](std::pair<BranchID, ThinnedAssociationBranches const*> const& x,
195  std::pair<BranchID, ThinnedAssociationBranches const*> const& y)
196  { return x.first < y.first; });
197  // This should never happen
198  if(branches == assocToBranches.end() || branches->first != association) {
200  "ThinnedAssociationHelper::initAssociationsFromSecondary could not find branches information, contact Framework developers");
201  }
202  requireMatch(*(branches->second));
203  }
204  }
Definition: helper.py:1
void requireMatch(ThinnedAssociationBranches const &input) const

Member Data Documentation

std::vector<ThinnedAssociationBranches> edm::ThinnedAssociationsHelper::vThinnedAssociationBranches_
private

Definition at line 83 of file ThinnedAssociationsHelper.h.