Skip to content

Commit b75dd8d

Browse files
committed
crimson/osd/pg: add is_missing_on_peer()
Signed-off-by: Xuehan Xu <[email protected]>
1 parent b6f27f8 commit b75dd8d

File tree

2 files changed

+6
-1
lines changed

2 files changed

+6
-1
lines changed

src/crimson/osd/pg.cc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1605,7 +1605,7 @@ bool PG::should_send_op(
16051605
// missing set
16061606
hoid <= peering_state.get_peer_info(peer).last_backfill ||
16071607
(has_backfill_state() && hoid <= get_last_backfill_started() &&
1608-
!peering_state.get_peer_missing(peer).is_missing(hoid)));
1608+
!is_missing_on_peer(peer, hoid)));
16091609
if (!should_send) {
16101610
ceph_assert(is_backfill_target(peer));
16111611
logger().debug("{} issue_repop shipping empty opt to osd."

src/crimson/osd/pg.h

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -901,6 +901,11 @@ class PG : public boost::intrusive_ref_counter<
901901
!peering_state.get_missing_loc().readable_with_acting(
902902
oid, get_actingset(), v);
903903
}
904+
bool is_missing_on_peer(
905+
const pg_shard_t &peer,
906+
const hobject_t &soid) const {
907+
return peering_state.get_peer_missing(peer).is_missing(soid);
908+
}
904909
bool is_degraded_or_backfilling_object(const hobject_t& soid) const;
905910
const std::set<pg_shard_t> &get_actingset() const {
906911
return peering_state.get_actingset();

0 commit comments

Comments
 (0)