EarlyDeleteHelper.cc

Go to the documentation of this file.

// -*- C++ -*-
//
// Package:     Framework
// Class  :     EarlyDeleteHelper
//
// Implementation:
//     [Notes on implementation]
//
// Original Author:  Chris Jones
//         Created:  Mon Feb  6 16:17:10 CST 2012
//

// system include files

// user include files
#include "DataFormats/Provenance/interface/BranchID.h"
#include "FWCore/Framework/interface/EventPrincipal.h"

#include "FWCore/Framework/interface/EarlyDeleteHelper.h"

using namespace edm;
//
// constants, enums and typedefs
//

//
// static data member definitions
//

//
// constructors and destructor
//
EarlyDeleteHelper::EarlyDeleteHelper(unsigned int* iBeginIndexItr,
                                     unsigned int* iEndIndexItr,
                                     std::vector<BranchToCount>* iBranchCounts)
    : pBeginIndex_(iBeginIndexItr),
      pEndIndex_(iEndIndexItr),
      pBranchCounts_(iBranchCounts),
      pathsLeftToComplete_(0),
      nPathsOn_(0) {}

EarlyDeleteHelper::EarlyDeleteHelper(const EarlyDeleteHelper& rhs)
    : pBeginIndex_(rhs.pBeginIndex_),
      pEndIndex_(rhs.pEndIndex_),
      pBranchCounts_(rhs.pBranchCounts_),
      pathsLeftToComplete_(rhs.pathsLeftToComplete_.load()),
      nPathsOn_(rhs.nPathsOn_) {}

//EarlyDeleteHelper::~EarlyDeleteHelper()
//{
//}

//
// assignment operators
//
// const EarlyDeleteHelper& EarlyDeleteHelper::operator=(const EarlyDeleteHelper& rhs)
// {
//   //An exception safe implementation is
//   EarlyDeleteHelper temp(rhs);
//   swap(rhs);
//
//   return *this;
// }

//
// member functions
//
void EarlyDeleteHelper::moduleRan(EventPrincipal const& iEvent) {
  pathsLeftToComplete_ = 0;
  for (auto it = pBeginIndex_; it != pEndIndex_; ++it) {
    auto& count = (*pBranchCounts_)[*it];
    assert(count.count > 0);
    auto value = --(count.count);
    if (value == 0) {
      iEvent.deleteProduct(count.branch);
    }
  }
}

void EarlyDeleteHelper::pathFinished(EventPrincipal const& iEvent) {
  unsigned int value = pathsLeftToComplete_;
  while (value > 0) {
    if (pathsLeftToComplete_.compare_exchange_strong(value, value - 1)) {
      //we were the thread that changed the value
      if (value == 1) {
        //we can never reach this module now so declare it as run
        moduleRan(iEvent);
      }
      break;
    }
  }
}

void EarlyDeleteHelper::appendIndex(unsigned int iIndex) {
  *pEndIndex_ = iIndex;
  ++pEndIndex_;
}

void EarlyDeleteHelper::shiftIndexPointers(unsigned int iShift) {
  pEndIndex_ -= iShift;
  pBeginIndex_ -= iShift;
}

//
// const member functions
//

//
// static member functions
//