osd/OSD: fix another race(clear outstanding_pg_stats)

Signed-off-by: xie xingguo <xie.xingguo@zte.com.cn>

diff --git a/src/osd/OSD.cc b/src/osd/OSD.cc
index f2faccadaa020ae6c3dc5e894f5e3171def7d48c..efe593dd8949a249a30becfe667bcdd7c917b6aa 100644 (file)
--- a/src/osd/OSD.cc
+++ b/src/osd/OSD.cc
@@ -7616,7 +7616,7 @@ void OSD::_committed_osd_maps(epoch_t first, epoch_t last, MOSDMap *m)
       dout(10) << __func__ << " require_osd_release reached luminous in "
               << newmap->get_epoch() << dendl;
       clear_pg_stat_queue();
-      outstanding_pg_stats.clear();
+      clear_outstanding_pg_stats();
     }
 
     osdmap = newmap;

diff --git a/src/osd/OSD.h b/src/osd/OSD.h
index 03b56735ec5a7565b854b00ed098d3d11b2f88ea..090888f31373fe2c3af3d3b50044ba3719ce6228 100644 (file)
--- a/src/osd/OSD.h
+++ b/src/osd/OSD.h
@@ -2113,6 +2113,10 @@ protected:
     }
     pg_stat_queue_lock.Unlock();
   }
+  void clear_outstanding_pg_stats(){
+    Mutex::Locker l(pg_stat_queue_lock);
+    outstanding_pg_stats.clear();
+  }
 
   ceph_tid_t get_tid() {
     return service.get_tid();