HFShowerLibrary::BranchReader Struct Reference

Public Member Functions
	BranchReader ()
	BranchReader (TBranch *iBranch, FileFormat iFormat, size_t iReadOffset, size_t maxRecordsToCache)
HFShowerPhotonCollection	getRecord (int) const
std::size_t	numberOfRecords () const

Private Member Functions
void	doCaching (size_t maxRecords)

Static Private Member Functions
static HFShowerPhotonCollection	getRecordNewForm (TBranch *, int iEntry)
static HFShowerPhotonCollection	getRecordNewFormV3 (TBranch *, int iEntry)
static HFShowerPhotonCollection	getRecordOldForm (TBranch *, int iEntry)
static std::shared_ptr< BranchCache const >	makeCache (BranchReader &, size_t maxRecordsToCache, std::string const &iFileName, std::string const &iBranchName)

Private Attributes
TBranch *	branch_
std::shared_ptr< BranchCache const >	cache_
FileFormat	format_
size_t	offset_

Detailed Description

Definition at line 93 of file HFShowerLibrary.h.

Constructor & Destructor Documentation

BranchReader() [1/2]

HFShowerLibrary::BranchReader::BranchReader ( )

inline

Definition at line 94 of file HFShowerLibrary.h.

: branch_(nullptr), offset_(0), format_(FileFormat::kOld) {}

BranchReader() [2/2]

HFShowerLibrary::BranchReader::BranchReader ( TBranch *  iBranch, FileFormat  iFormat, size_t  iReadOffset, size_t  maxRecordsToCache  )

inline

Definition at line 95 of file HFShowerLibrary.h.

References branch_, and doCaching().

        : branch_(iBranch), offset_(iReadOffset), format_(iFormat) {
      if (0 < maxRecordsToCache) {
        doCaching(maxRecordsToCache);
        branch_ = nullptr;
      }
    }

Member Function Documentation

doCaching()

void HFShowerLibrary::BranchReader::doCaching ( size_t  maxRecords )

private

Definition at line 440 of file HFShowerLibrary.cc.

Referenced by BranchReader().

                                                                    {
  cache_ = makeCache(*this, maxRecordsToCache, branch_->GetDirectory()->GetFile()->GetName(), branch_->GetName());
}

getRecord()

HFShowerPhotonCollection HFShowerLibrary::BranchReader::getRecord

(

int

record

)

const

Definition at line 501 of file HFShowerLibrary.cc.

References HFShowerLibrary::kNew, HFShowerLibrary::kNewV3, HFShowerLibrary::kOld, and AlCaHarvesting_cff::record.

Referenced by HFShowerLibrary::BranchCache::BranchCache(), and HFShowerLibrary::getRecord().

                                                                                {
  if (cache_) {
    return cache_->getRecord(record);
  }
  int nrc = record - 1;
  HFShowerPhotonCollection photo;

  switch (format_) {
    case FileFormat::kNew: {
      photo = getRecordNewForm(branch_, nrc + offset_);
      break;
    }
    case FileFormat::kNewV3: {
      photo = getRecordNewFormV3(branch_, nrc + offset_);
      break;
    }
    case FileFormat::kOld: {
      photo = getRecordOldForm(branch_, nrc);
      break;
    }
  }
  return photo;
}

getRecordNewForm()

HFShowerPhotonCollection HFShowerLibrary::BranchReader::getRecordNewForm ( TBranch *  iBranch, int  iEntry  )

staticprivate

Definition at line 475 of file HFShowerLibrary.cc.

References eostools::move(), and groupFilesInBlocks::temp.

                                                                                                   {
  HFShowerPhotonCollection photo;

  auto temp = std::make_unique<HFShowerPhotonCollection>();
  iBranch->SetAddress(&temp);
  iBranch->GetEntry(iEntry);
  photo = std::move(*temp);

  return photo;
}

getRecordNewFormV3()

HFShowerPhotonCollection HFShowerLibrary::BranchReader::getRecordNewFormV3 ( TBranch *  iBranch, int  iEntry  )

staticprivate

Definition at line 485 of file HFShowerLibrary.cc.

References mps_fire::i, submitPVValidationJobs::t, and cmsswSequenceInfo::tp.

                                                                                                     {
  HFShowerPhotonCollection photo;

  std::vector<float> t;
  std::vector<float>* tp = &t;
  iBranch->SetAddress(&tp);
  iBranch->GetEntry(iEntry);
  unsigned int tSize = t.size() / 5;
  photo.reserve(tSize);
  for (unsigned int i = 0; i < tSize; i++) {
    photo.emplace_back(t[i], t[1 * tSize + i], t[2 * tSize + i], t[3 * tSize + i], t[4 * tSize + i]);
  }

  return photo;
}

getRecordOldForm()

HFShowerPhotonCollection HFShowerLibrary::BranchReader::getRecordOldForm ( TBranch *  iBranch, int  iEntry  )

staticprivate

Definition at line 469 of file HFShowerLibrary.cc.

                                                                                                   {
  HFShowerPhotonCollection photo;
  iBranch->SetAddress(&photo);
  iBranch->GetEntry(iEntry);
  return photo;
}

makeCache()

std::shared_ptr< HFShowerLibrary::BranchCache const > HFShowerLibrary::BranchReader::makeCache ( BranchReader &  iReader, size_t  maxRecordsToCache, std::string const &  iFileName, std::string const &  iBranchName  )

staticprivate

Definition at line 444 of file HFShowerLibrary.cc.

References CMS_SA_ALLOW, mutex, s_mutex, and findQualityFiles::v.

                                                                                                               {
  //This allows sharing of the same cached data across the different modules (e.g. the per stream instances of OscarMTProducer
  CMS_SA_ALLOW static std::mutex s_mutex;
  std::lock_guard<std::mutex> guard(s_mutex);
  CMS_SA_ALLOW static std::map<std::pair<std::string, std::string>, std::weak_ptr<BranchCache>> s_map;
  auto v = s_map[{iFileName, iBranchName}].lock();
  if (v) {
    return v;
  }
  v = std::make_shared<BranchCache>(iReader, maxRecordsToCache);
  s_map[{iFileName, iBranchName}] = v;
  return v;
}

numberOfRecords()

size_t HFShowerLibrary::BranchReader::numberOfRecords

(

)

const

Definition at line 525 of file HFShowerLibrary.cc.

Referenced by HFShowerLibrary::BranchCache::BranchCache().

{ return branch_->GetEntries() - offset_; }

Member Data Documentation

branch_

TBranch* HFShowerLibrary::BranchReader::branch_

private

Definition at line 118 of file HFShowerLibrary.h.

Referenced by BranchReader(), tree.Tree::var(), and tree.Tree::vector().

cache_

std::shared_ptr<BranchCache const> HFShowerLibrary::BranchReader::cache_

private

Definition at line 119 of file HFShowerLibrary.h.

format_

FileFormat HFShowerLibrary::BranchReader::format_

private

Definition at line 121 of file HFShowerLibrary.h.

offset_

size_t HFShowerLibrary::BranchReader::offset_

private

Definition at line 120 of file HFShowerLibrary.h.