mirror of
https://github.com/dragonflydb/dragonfly.git
synced 2025-05-10 18:05:44 +02:00
fix(transaction): Use FinishHop in schedule (#2911)
This commit is contained in:
parent
8030ee96b5
commit
64d963dbbe
1 changed files with 1 additions and 1 deletions
|
@ -728,7 +728,7 @@ void Transaction::ScheduleInternal() {
|
||||||
if (!ScheduleInShard(EngineShard::tlocal(), can_run_immediately)) {
|
if (!ScheduleInShard(EngineShard::tlocal(), can_run_immediately)) {
|
||||||
schedule_fails.fetch_add(1, memory_order_relaxed);
|
schedule_fails.fetch_add(1, memory_order_relaxed);
|
||||||
}
|
}
|
||||||
run_barrier_.Dec();
|
FinishHop();
|
||||||
};
|
};
|
||||||
|
|
||||||
run_barrier_.Start(unique_shard_cnt_);
|
run_barrier_.Start(unique_shard_cnt_);
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue