From 3636dc3598b7022bff623d686cbee83ed288d966 Mon Sep 17 00:00:00 2001 From: Leonid Chernin Date: Mon, 8 Dec 2025 22:54:44 +0200 Subject: [PATCH] nvmeofgw: prevent map corruption while processing beacons from deleted gws Fix race issue of map corruption when deleted gw sends beacons but this gw data was removed from pending map and still exists in map. Process beacons only if GW's data exists in both maps: main-map and pending-map, otherwise just ignore beacons. fixes: https://tracker.ceph.com/issues/74160 Signed-off-by: Leonid Chernin --- src/mon/NVMeofGwMon.cc | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/src/mon/NVMeofGwMon.cc b/src/mon/NVMeofGwMon.cc index 9809b9eff610..b4c5113ff376 100644 --- a/src/mon/NVMeofGwMon.cc +++ b/src/mon/NVMeofGwMon.cc @@ -902,6 +902,10 @@ bool NVMeofGwMon::prepare_beacon(MonOpRequestRef op) NVMEOFHAMAP); auto& group_gws = map.created_gws[group_key]; auto gw = group_gws.find(gw_id); + auto& pend_gws = pending_map.created_gws[group_key]; + auto pend_gw = pend_gws.find(gw_id); + + bool gw_exists = (gw != group_gws.end() && (pend_gw != pend_gws.end())); const BeaconSubsystems& sub = m->get_subsystems(); auto now = ceph::coarse_mono_clock::now(); int beacons_till_ack = @@ -910,7 +914,7 @@ bool NVMeofGwMon::prepare_beacon(MonOpRequestRef op) bool send_ack = false; if (avail == gw_availability_t::GW_CREATED) { - if (gw == group_gws.end()) { + if (!gw_exists) { gw_created = false; dout(10) << "Warning: GW " << gw_id << " group_key " << group_key << " was not found in the map.created_gws " @@ -947,7 +951,7 @@ bool NVMeofGwMon::prepare_beacon(MonOpRequestRef op) // gw already created } else { // first GW beacon should come with avail = Created // if GW reports Avail/Unavail but in monitor's database it is Unavailable - if (gw != group_gws.end()) { + if (gw_exists) { correct_sequence = pending_map.put_gw_beacon_sequence_number (gw_id, version, group_key, sequence, stored_sequence); // it means it did not perform "exit" after failover was set by @@ -982,7 +986,7 @@ bool NVMeofGwMon::prepare_beacon(MonOpRequestRef op) } } // Beacon from GW in !Created state but it does not appear in the map - if (gw == group_gws.end()) { + if (!gw_exists) { dout(4) << "GW that does not appear in the map sends beacon, ignore " << gw_id << dendl; mon.no_reply(op); -- 2.47.3