early file delete fix for DAQSource

cms-sw · Jul 13, 2023 · c242531 · c242531
1 parent 7251a56
commit c242531
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/EventFilter/Utilities/interface/DAQSource.h b/EventFilter/Utilities/interface/DAQSource.h
@@ -159,7 +159,6 @@ class DAQSource : public edm::RawInputSource {
   std::list<std::pair<int, std::unique_ptr<InputFile>>> filesToDelete_;
   std::mutex fileDeleteLock_;
   std::vector<int> streamFileTracker_;
-  unsigned int nStreams_ = 0;
   unsigned int checkEvery_ = 10;
 
   //supervisor thread wakeup

diff --git a/EventFilter/Utilities/src/DAQSource.cc b/EventFilter/Utilities/src/DAQSource.cc
@@ -556,7 +556,7 @@ void DAQSource::read(edm::EventPrincipal& eventPrincipal) {
     auto it = filesToDelete_.begin();
     while (it != filesToDelete_.end()) {
       bool fileIsBeingProcessed = false;
-      for (unsigned int i = 0; i < nStreams_; i++) {
+      for (unsigned int i = 0; i < streamFileTracker_.size(); i++) {
         if (it->first == streamFileTracker_.at(i)) {
           fileIsBeingProcessed = true;
           break;