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

Use set_immediate() in osd_flush to prevent stack overflows on repeated errors

Browse Source
This commit is contained in:
Vitaliy Filippov
2025-08-10 17:58:01 +03:00
parent 918ea34af2
commit 4793dbe9c3
1 changed files with 18 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/osd/osd_flush.cpp
+18 -15
View File
@@ -310,22 +310,25 @@ void osd_t::submit_recovery_op(osd_recovery_op_t *op)
op->osd_op->peer_fd = -1; op->osd_op->peer_fd = -1;
op->osd_op->callback = [this, op](osd_op_t *osd_op) op->osd_op->callback = [this, op](osd_op_t *osd_op)
{ {
if (osd_op->reply.hdr.retval < 0) ringloop->set_immediate([this, op]()
{ {
// Error recovering object if (op->osd_op->reply.hdr.retval < 0)
// EPIPE is totally harmless (peer is gone), others like EIO/EDOM may be not {
printf( // Error recovering object
"[PG %u/%u] Recovery operation failed with object %jx:%jx: error %jd\n", // EPIPE is totally harmless (peer is gone), others like EIO/EDOM may be not
INODE_POOL(op->oid.inode), printf(
map_to_pg(op->oid, st_cli.pool_config.at(INODE_POOL(op->oid.inode)).pg_stripe_size), "[PG %u/%u] Recovery operation failed with object %jx:%jx: error %jd\n",
op->oid.inode, op->oid.stripe, osd_op->reply.hdr.retval INODE_POOL(op->oid.inode),
); map_to_pg(op->oid, st_cli.pool_config.at(INODE_POOL(op->oid.inode)).pg_stripe_size),
} op->oid.inode, op->oid.stripe, op->osd_op->reply.hdr.retval
else if (log_level > 2) );
{ }
printf("Recovery operation done for %jx:%jx\n", op->oid.inode, op->oid.stripe); else if (log_level > 2)
} {
finish_recovery_op(op); printf("Recovery operation done for %jx:%jx\n", op->oid.inode, op->oid.stripe);
}
finish_recovery_op(op);
});
}; };
exec_op(op->osd_op); exec_op(op->osd_op);
} }