Skip to content

Commit

Permalink
save
Browse files Browse the repository at this point in the history
  • Loading branch information
ryoqun committed Nov 25, 2023
1 parent 4c5c98c commit ee6f330
Showing 1 changed file with 2 additions and 5 deletions.
7 changes: 2 additions & 5 deletions scheduler-pool/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1487,7 +1487,7 @@ impl ScheduleStage {
) -> Option<TaskInQueue> {
let from_runnable = matches!(task_source, TaskSource::Runnable);

let (lock_success_count, uncommited_usages) = Self::attempt_lock_for_execution(
let (lock_success_count, usages) = Self::attempt_lock_for_execution(
&next_task.unique_weight,
&mut next_task.lock_attempts_mut(),
from_runnable,
Expand All @@ -1508,10 +1508,7 @@ impl ScheduleStage {
trace!("successful lock: (from_runnable: {})", from_runnable,);

if !from_runnable {
for (usage, attempt) in uncommited_usages
.into_iter()
.zip(next_task.lock_attempts_mut().iter())
{
for (usage, attempt) in usages.into_iter().zip(next_task.lock_attempts_mut().iter()) {
attempt.target_page_mut().current_usage = usage;
}
// as soon as next tack is succeeded in locking, trigger re-checks on read only
Expand Down

0 comments on commit ee6f330

Please sign in to comment.