edm::EarlyDeleteHelper Class Reference

#include <EarlyDeleteHelper.h>

Public Member Functions
void	addedToPath ()
void	appendIndex (unsigned int index)
unsigned int *	begin ()
	EarlyDeleteHelper (unsigned int *iBeginIndexItr, unsigned int *iEndIndexItr, std::vector< BranchToCount > *iBranchCounts)
	EarlyDeleteHelper (const EarlyDeleteHelper &)
unsigned int *	end ()
void	moduleRan (EventPrincipal const &)
EarlyDeleteHelper &	operator= (const EarlyDeleteHelper &)=default
void	pathFinished (EventPrincipal const &)
void	reset ()
void	shiftIndexPointers (unsigned int iShift)

Private Attributes
unsigned int	nPathsOn_
std::atomic< unsigned int >	pathsLeftToComplete_
unsigned int *	pBeginIndex_
std::vector< BranchToCount > *	pBranchCounts_
unsigned int *	pEndIndex_

Detailed Description

Definition at line 44 of file EarlyDeleteHelper.h.

Constructor & Destructor Documentation

EarlyDeleteHelper::EarlyDeleteHelper	(	unsigned int *	iBeginIndexItr,
		unsigned int *	iEndIndexItr,
		std::vector< BranchToCount > *	iBranchCounts
	)

Definition at line 33 of file EarlyDeleteHelper.cc.

                                                                             :
pBeginIndex_(iBeginIndexItr),
pEndIndex_(iEndIndexItr),
pBranchCounts_(iBranchCounts),
pathsLeftToComplete_(0),
nPathsOn_(0)
{
}

EarlyDeleteHelper::EarlyDeleteHelper

(

const EarlyDeleteHelper &

rhs

)

Definition at line 44 of file EarlyDeleteHelper.cc.

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

Member Function Documentation

void edm::EarlyDeleteHelper::addedToPath ( )

inline

Definition at line 63 of file EarlyDeleteHelper.h.

{ ++nPathsOn_;}

void EarlyDeleteHelper::appendIndex

(

unsigned int

index

)

Definition at line 102 of file EarlyDeleteHelper.cc.

References pEndIndex_.

                                                  {
  *pEndIndex_=iIndex;
  ++pEndIndex_;
}

unsigned int* edm::EarlyDeleteHelper::begin ( void  )

inline

Definition at line 67 of file EarlyDeleteHelper.h.

{ return pBeginIndex_;}

unsigned int* edm::EarlyDeleteHelper::end ( void  )

inline

Definition at line 68 of file EarlyDeleteHelper.h.

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

{ return pEndIndex_;}

void EarlyDeleteHelper::moduleRan

(

EventPrincipal const &

iEvent

)

Definition at line 74 of file EarlyDeleteHelper.cc.

References KineDebug3::count(), edm::Principal::deleteProduct(), pathsLeftToComplete_, pBeginIndex_, and pEndIndex_.

Referenced by pathFinished().

                                                         {
  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);
    }
  }
}

EarlyDeleteHelper& edm::EarlyDeleteHelper::operator= ( const EarlyDeleteHelper &  )

default

void EarlyDeleteHelper::pathFinished

(

EventPrincipal const &

iEvent

)

Definition at line 87 of file EarlyDeleteHelper.cc.

References moduleRan(), and pathsLeftToComplete_.

                                                            {
  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 edm::EarlyDeleteHelper::reset ( void  )

inline

Definition at line 60 of file EarlyDeleteHelper.h.

{pathsLeftToComplete_ = nPathsOn_;}

void EarlyDeleteHelper::shiftIndexPointers

(

unsigned int

iShift

)

Definition at line 108 of file EarlyDeleteHelper.cc.

References pBeginIndex_, and pEndIndex_.

                                                         {
  pEndIndex_ -=iShift;
  pBeginIndex_ -=iShift;
}

Member Data Documentation

unsigned int edm::EarlyDeleteHelper::nPathsOn_

private

Definition at line 77 of file EarlyDeleteHelper.h.

std::atomic<unsigned int> edm::EarlyDeleteHelper::pathsLeftToComplete_

private

Definition at line 76 of file EarlyDeleteHelper.h.

Referenced by moduleRan(), and pathFinished().

unsigned int* edm::EarlyDeleteHelper::pBeginIndex_

private

Definition at line 73 of file EarlyDeleteHelper.h.

Referenced by moduleRan(), and shiftIndexPointers().

std::vector<BranchToCount>* edm::EarlyDeleteHelper::pBranchCounts_

private

Definition at line 75 of file EarlyDeleteHelper.h.

unsigned int* edm::EarlyDeleteHelper::pEndIndex_

private

Definition at line 74 of file EarlyDeleteHelper.h.

Referenced by appendIndex(), moduleRan(), and shiftIndexPointers().