Skip to content

Commit dd8940b

Browse files
committed
Do not clean up copied files 1 by 1 in case looping was requested
1 parent 1fb3c1b commit dd8940b

File tree

2 files changed

+3
-4
lines changed

2 files changed

+3
-4
lines changed

Common/Utils/src/FileFetcher.cxx

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -265,8 +265,7 @@ void FileFetcher::fetcher()
265265
while (mRunning) {
266266
mNLoops = mNFilesProc / getNFiles();
267267
if (mNLoops > mMaxLoops) {
268-
mNLoops--;
269-
LOGP(INFO, "Finished file fetching: {} of {} files fetched successfully in {} loops", mNFilesProcOK, mNFilesProc, mMaxLoops);
268+
LOGP(INFO, "Finished file fetching: {} of {} files fetched successfully in {} iterations", mNFilesProcOK, mNFilesProc, mMaxLoops);
270269
mRunning = false;
271270
break;
272271
}
@@ -276,7 +275,7 @@ void FileFetcher::fetcher()
276275
}
277276
fileEntry = (fileEntry + 1) % getNFiles();
278277
if (fileEntry == 0 && mNLoops > 0) {
279-
LOG(INFO) << "Fetcher starts new loop " << mNLoops;
278+
LOG(INFO) << "Fetcher starts new iteration " << mNLoops;
280279
}
281280
mNFilesProc++;
282281
auto& fileRef = mInputFiles[fileEntry];

Detectors/CTF/workflow/src/CTFReaderSpec.cxx

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -361,7 +361,7 @@ void CTFReaderSpec::checkTreeEntries()
361361
mCTFFile->Close();
362362
mCTFFile.reset();
363363
if (mFileFetcher) {
364-
mFileFetcher->popFromQueue(mFileFetcher->getNLoops() >= mInput.maxLoops);
364+
mFileFetcher->popFromQueue(mInput.maxLoops < 1);
365365
}
366366
}
367367
}

0 commit comments

Comments
 (0)