Skip to content

Commit 6981b4f

Browse files
committed
tfscheduler: clear stfmap on run reset
1 parent 04580d6 commit 6981b4f

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

src/TfScheduler/TfSchedulerStfInfo.cxx

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -437,7 +437,7 @@ void TfSchedulerStfInfo::addStfInfo(const StfSenderStfInfo &pStfInfo, SchedulerS
437437
reset();
438438
mRunNumber = lRunNumber;
439439
} else if (mRunNumber > lRunNumber) {
440-
EDDLOG("New RunNumber is smaller than the previous. run_number={} prev_run_number={}", lRunNumber, mRunNumber);
440+
EDDLOG_GRL(500, "New RunNumber is smaller than the previous. run_number={} prev_run_number={}", lRunNumber, mRunNumber);
441441
pResponse.set_status((!mRunning) ? SchedulerStfInfoResponse::DROP_NOT_RUNNING :
442442
SchedulerStfInfoResponse::DROP_SCHED_DISCARDED);
443443
return;

src/TfScheduler/TfSchedulerStfInfo.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -185,7 +185,6 @@ class TfSchedulerStfInfo
185185

186186
void reset() {
187187
// NOTE: only call when holding mGlobalStfInfoLock
188-
189188
mLastStfId = 0;
190189
mMaxCompletedTfId = 0;
191190
mNotScheduledTfsCount = 0;
@@ -196,6 +195,7 @@ class TfSchedulerStfInfo
196195
if (!mStfInfoMap.empty()) {
197196
WDDLOG("TfSchedulerStfInfo::reset(): StfInfoMap not empty. size={}", mStfInfoMap.size());
198197
}
198+
mStfInfoMap.clear();
199199
}
200200

201201
inline void requestDropAllLocked(const std::uint64_t lStfId) {

0 commit comments

Comments
 (0)