]> git.apps.os.sepia.ceph.com Git - ceph-ci.git/commitdiff
osd: do not check for CEPH_OSDMAP_FULL anymore
authorKefu Chai <kchai@redhat.com>
Fri, 27 Sep 2019 07:46:31 +0000 (15:46 +0800)
committerKefu Chai <kchai@redhat.com>
Sat, 28 Sep 2019 08:09:58 +0000 (16:09 +0800)
per-pool full flag has taken the place of it since
b4ca5ae462c6f12ca48b787529938862646282cd

Signed-off-by: Kefu Chai <kchai@redhat.com>
src/osd/OSD.cc
src/osd/PeeringState.cc
src/osd/PrimaryLogPG.cc

index 8f8618249b0209a00615b22470fa35e4710c9c7e..2ad6293d150cd8cade9df8d19e8ab2c73ab03265 100644 (file)
@@ -8963,11 +8963,6 @@ void OSD::activate_map()
 
   dout(7) << "activate_map version " << osdmap->get_epoch() << dendl;
 
-  if (osdmap->test_flag(CEPH_OSDMAP_FULL)) {
-    dout(10) << " osdmap flagged full, doing onetime osdmap subscribe" << dendl;
-    osdmap_subscribe(osdmap->get_epoch() + 1, false);
-  }
-
   // norecover?
   if (osdmap->test_flag(CEPH_OSDMAP_NORECOVER)) {
     if (!service.recovery_is_paused()) {
index 008fa52ba98c2cfd51c5009c539823d674e9bd5c..d62dd19e21937bdefcc65204d3ecfeb721879712 100644 (file)
@@ -463,17 +463,11 @@ void PeeringState::complete_flush()
 
 void PeeringState::check_full_transition(OSDMapRef lastmap, OSDMapRef osdmap)
 {
-  bool changed = false;
-  if (osdmap->test_flag(CEPH_OSDMAP_FULL) &&
-      !lastmap->test_flag(CEPH_OSDMAP_FULL)) {
-    psdout(10) << " cluster was marked full in "
-              << osdmap->get_epoch() << dendl;
-    changed = true;
-  }
   const pg_pool_t *pi = osdmap->get_pg_pool(info.pgid.pool());
   if (!pi) {
     return; // pool deleted
   }
+  bool changed = false;
   if (pi->has_flag(pg_pool_t::FLAG_FULL)) {
     const pg_pool_t *opi = lastmap->get_pg_pool(info.pgid.pool());
     if (!opi || !opi->has_flag(pg_pool_t::FLAG_FULL)) {
index 3c49fae93186631dcbfa7f692e6b44ca2ce87cbb..a9c167641892ebe177b9a334cd6295674c1527b5 100644 (file)
@@ -8287,8 +8287,7 @@ int PrimaryLogPG::prepare_transaction(OpContext *ctx)
   // check for full
   if ((ctx->delta_stats.num_bytes > 0 ||
        ctx->delta_stats.num_objects > 0) &&  // FIXME: keys?
-      (pool.info.has_flag(pg_pool_t::FLAG_FULL) ||
-       get_osdmap()->test_flag(CEPH_OSDMAP_FULL))) {
+      pool.info.has_flag(pg_pool_t::FLAG_FULL)) {
     auto m = ctx->op->get_req<MOSDOp>();
     if (ctx->reqid.name.is_mds() ||   // FIXME: ignore MDS for now
        m->has_flag(CEPH_OSD_FLAG_FULL_FORCE)) {