thebestvibedev/tromcho.net
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix throttling with the new store

Browse Source
This commit is contained in:
Vitaliy Filippov
2026-03-01 23:46:30 +00:00
parent a95a60c600
commit 33b561b73a
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/blockstore/blockstore_write.cpp
+2 -1
View File
@@ -404,11 +404,12 @@ resume_6:
if (ref_us > exec_us + throttle_threshold_us) if (ref_us > exec_us + throttle_threshold_us)
{ {
// Pause reply // Pause reply
PRIV(op)->pending_ops++;
PRIV(op)->op_state = 7; PRIV(op)->op_state = 7;
// Remember that the timer can in theory be called right here // Remember that the timer can in theory be called right here
tfd->set_timer_us(ref_us-exec_us, false, [this, op](int timer_id) tfd->set_timer_us(ref_us-exec_us, false, [this, op](int timer_id)
{ {
PRIV(op)->op_state = 8; PRIV(op)->pending_ops--;
ringloop->wakeup(); ringloop->wakeup();
}); });
return 1; return 1;