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

Mark OSDs as dirty during deletes more correctly

Browse Source
This commit is contained in:
Vitaliy Filippov
2026-05-11 12:56:23 +03:00
parent caa70317fa
commit a8e821b13b
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/osd/osd_primary.cpp
+5 -5
View File
@@ -780,6 +780,11 @@ resume_5:
} }
// Remove version override // Remove version override
pg.ver_override.erase(op_data->oid); pg.ver_override.erase(op_data->oid);
// Mark PG and OSDs as dirty
for (auto & chunk: (op_data->object_state ? op_data->object_state->osd_set : pg.cur_loc_set))
{
this->dirty_osds.insert(chunk.osd_num);
}
// Adjust PG stats after "instant stabilize", because we need object_state above // Adjust PG stats after "instant stabilize", because we need object_state above
if (!op_data->object_state) if (!op_data->object_state)
{ {
@@ -790,11 +795,6 @@ resume_5:
remove_object_from_state(op_data->oid, &op_data->object_state, pg); remove_object_from_state(op_data->oid, &op_data->object_state, pg);
deref_object_state(pg, &op_data->object_state, true); deref_object_state(pg, &op_data->object_state, true);
} }
// Mark PG and OSDs as dirty
for (auto & chunk: (op_data->object_state ? op_data->object_state->osd_set : pg.cur_loc_set))
{
this->dirty_osds.insert(chunk.osd_num);
}
for (auto cl_it = msgr.clients.find(cur_op->client_id); cl_it != msgr.clients.end(); ) for (auto cl_it = msgr.clients.find(cur_op->client_id); cl_it != msgr.clients.end(); )
{ {
cl_it->second->dirty_pgs.insert({ .pool_id = pg.pool_id, .pg_num = pg.pg_num }); cl_it->second->dirty_pgs.insert({ .pool_id = pg.pool_id, .pg_num = pg.pg_num });