Skip to content

Commit

Permalink
bugfix:flush needs to lock the corresponding queue lock
Browse files Browse the repository at this point in the history
  • Loading branch information
HanJinChi committed Sep 20, 2024
1 parent f79f76a commit 2062887
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions util/parallel_regression.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -126,6 +126,7 @@ class ParallelRegressionGen : public RegressionGen<NC, EnIC, TestFlush, PAddrN,
xact_cond[i]->wait(lk, [&, i]{return xact_queue[i].empty();});
xact_queue[i].push_back(act);
}
std::unique_lock lk(*xact_mutux[core]);
xact_queue[core].push_back(act);
}else{
std::unique_lock lk(*xact_mutux[core]);
Expand Down

0 comments on commit 2062887

Please sign in to comment.