From: Matan Breizman Date: Tue, 15 Jul 2025 08:24:06 +0000 (+0000) Subject: crimson/osd/../client_request: rename is_misdirected and add logs X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=9dcd329b51b78c6c3145bf0dd1750963bc72ccd6;p=ceph.git crimson/osd/../client_request: rename is_misdirected and add logs This function mainly verifies replicated read related info. Signed-off-by: Matan Breizman --- diff --git a/src/crimson/osd/osd_operations/client_request.cc b/src/crimson/osd/osd_operations/client_request.cc index d32402ab223..cfb85bc83b4 100644 --- a/src/crimson/osd/osd_operations/client_request.cc +++ b/src/crimson/osd/osd_operations/client_request.cc @@ -195,7 +195,7 @@ ClientRequest::interruptible_future<> ClientRequest::with_pg_process_interruptib if (!pg.is_primary()) { // primary can handle both normal ops and balanced reads - if (is_misdirected(pg)) { + if (is_misdirected_replica_read(pg)) { DEBUGDPP("{}.{}: dropping misdirected op", pg, *this, this_instance_id); co_return; @@ -625,24 +625,24 @@ ClientRequest::do_process( } } -bool ClientRequest::is_misdirected(const PG& pg) const +bool ClientRequest::is_misdirected_replica_read(const PG& pg) const { + LOG_PREFIX(ClientRequest::is_misdirected_replica_read); // otherwise take a closer look if (const int flags = m->get_flags(); flags & CEPH_OSD_FLAG_BALANCE_READS || flags & CEPH_OSD_FLAG_LOCALIZE_READS) { if (!op_info.may_read()) { - // no read found, so it can't be balanced read + DEBUGDPP("{}: dropping - no read found with balanced/localize read", pg, *this); return true; } if (op_info.may_write() || op_info.may_cache()) { - // write op, but i am not primary + DEBUGDPP("{}: dropping - can't write to replica", pg, *this); return true; } - // balanced reads; any replica will do return false; } - // neither balanced nor localize reads + DEBUGDPP("{}: dropping - not a balanced/localize read ", pg, *this); return true; } diff --git a/src/crimson/osd/osd_operations/client_request.h b/src/crimson/osd/osd_operations/client_request.h index 4dfb735041b..006400aa9c6 100644 --- a/src/crimson/osd/osd_operations/client_request.h +++ b/src/crimson/osd/osd_operations/client_request.h @@ -269,7 +269,7 @@ private: ::crimson::osd::IOInterruptCondition, Errorator>; - bool is_misdirected(const PG& pg) const; + bool is_misdirected_replica_read(const PG& pg) const; const SnapContext get_snapc( PG &pg,