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

Block sync by all previous syncs

Browse Source
This commit is contained in:
Vitaliy Filippov
2026-05-11 16:33:49 +03:00
parent f78d7d4efc
commit f271c8450c
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/blockstore/blockstore_impl.cpp
+8 -3
View File
@@ -101,6 +101,7 @@ void blockstore_impl_t::loop()
unsigned initial_ring_space = ringloop->space_left(); unsigned initial_ring_space = ringloop->space_left();
int op_idx = 0, new_idx = 0; int op_idx = 0, new_idx = 0;
bool has_unfinished_writes = false; bool has_unfinished_writes = false;
bool has_unfinished_sync = false;
for (; op_idx < submit_queue.size(); op_idx++, new_idx++) for (; op_idx < submit_queue.size(); op_idx++, new_idx++)
{ {
auto op = submit_queue[op_idx]; auto op = submit_queue[op_idx];
@@ -138,7 +139,13 @@ void blockstore_impl_t::loop()
else if (op->opcode == BS_OP_SYNC) else if (op->opcode == BS_OP_SYNC)
{ {
// syncs only completed writes, so doesn't have to be blocked by anything // syncs only completed writes, so doesn't have to be blocked by anything
wr_st = continue_sync(op); if (!has_unfinished_sync)
{
wr_st = continue_sync(op);
has_unfinished_sync = (wr_st != 2);
}
else
wr_st = 0;
} }
else if (op->opcode == BS_OP_STABLE || op->opcode == BS_OP_ROLLBACK) else if (op->opcode == BS_OP_STABLE || op->opcode == BS_OP_ROLLBACK)
{ {
@@ -154,9 +161,7 @@ void blockstore_impl_t::loop()
wr_st = 2; wr_st = 2;
} }
else else
{
wr_st = 0; wr_st = 0;
}
} }
if (wr_st == 2) if (wr_st == 2)
{ {