]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
osdc/Objecter: remove unused on_reg_ack
authorSage Weil <sage@redhat.com>
Sat, 7 Feb 2015 14:50:38 +0000 (06:50 -0800)
committerSage Weil <sage@redhat.com>
Sat, 7 Feb 2015 14:50:38 +0000 (06:50 -0800)
This is all dead code.

Signed-off-by: Sage Weil <sage@redhat.com>
src/osdc/Objecter.cc
src/osdc/Objecter.h

index 20f89767226bf437c6ba360663d637603388cdbc..61098497d9795a2d2f51946867d45765a2000367 100644 (file)
@@ -430,8 +430,6 @@ void Objecter::_send_linger(LingerOp *info)
   } else {
     ldout(cct, 15) << "send_linger " << info->linger_id << " register" << dendl;
     opv = info->ops;
-    if (info->on_reg_ack)
-      onack = new C_Linger_Register(this, info);
     oncommit = new C_Linger_Commit(this, info);
   }
   Op *o = new Op(info->target.base_oid, info->target.base_oloc,
@@ -467,15 +465,6 @@ void Objecter::_send_linger(LingerOp *info)
   logger->inc(l_osdc_linger_send);
 }
 
-void Objecter::_linger_register(LingerOp *info, int r)
-{
-  ldout(cct, 10) << "_linger_register " << info->linger_id << dendl;
-  if (info->on_reg_ack) {
-    info->on_reg_ack->complete(r);
-    info->on_reg_ack = NULL;
-  }
-}
-
 void Objecter::_linger_commit(LingerOp *info, int r) 
 {
   ldout(cct, 10) << "_linger_commit " << info->linger_id << dendl;
@@ -689,7 +678,6 @@ ceph_tid_t Objecter::linger_watch(LingerOp *info,
   info->inbl = inbl;
   info->poutbl = NULL;
   info->pobjver = objver;
-  info->on_reg_ack = NULL;
   info->on_reg_commit = oncommit;
 
   RWLock::WLocker wl(rwlock);
@@ -1389,9 +1377,6 @@ void Objecter::_check_linger_pool_dne(LingerOp *op, bool *need_unregister)
   }
   if (op->map_dne_bound > 0) {
     if (osdmap->get_epoch() >= op->map_dne_bound) {
-      if (op->on_reg_ack) {
-       op->on_reg_ack->complete(-ENOENT);
-      }
       if (op->on_reg_commit) {
        op->on_reg_commit->complete(-ENOENT);
       }
index ff7cb891f72a625fefd1626e55b994a89d619f7b..ed44be004257fd7b20e416aebda062405e4bc327 100644 (file)
@@ -1520,7 +1520,7 @@ public:
     uint32_t register_gen;
     bool registered;
     bool canceled;
-    Context *on_reg_ack, *on_reg_commit;
+    Context *on_reg_commit;
 
     // we trigger these from an async finisher
     Context *on_notify_finish;
@@ -1554,7 +1554,7 @@ public:
                 register_gen(0),
                 registered(false),
                 canceled(false),
-                on_reg_ack(NULL), on_reg_commit(NULL),
+                on_reg_commit(NULL),
                 on_notify_finish(NULL),
                 notify_result_bl(NULL),
                 watch_context(NULL),
@@ -1577,20 +1577,6 @@ public:
     }
   };
 
-  struct C_Linger_Register : public Context {
-    Objecter *objecter;
-    LingerOp *info;
-    C_Linger_Register(Objecter *o, LingerOp *l) : objecter(o), info(l) {
-      info->get();
-    }
-    ~C_Linger_Register() {
-      info->put();
-    }
-    void finish(int r) {
-      objecter->_linger_register(info, r);
-    }
-  };
-  
   struct C_Linger_Commit : public Context {
     Objecter *objecter;
     LingerOp *info;
@@ -1748,7 +1734,6 @@ public:
 
   void _linger_submit(LingerOp *info);
   void _send_linger(LingerOp *info);
-  void _linger_register(LingerOp *info, int r);
   void _linger_commit(LingerOp *info, int r);
   void _linger_reconnect(LingerOp *info, int r);
   void _send_linger_ping(LingerOp *info);