]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
osdc/Objecter: don't use post_rx_buffer or revoke_rx_buffer at all
authorSage Weil <sage@redhat.com>
Fri, 1 Mar 2019 20:09:16 +0000 (14:09 -0600)
committerSage Weil <sage@redhat.com>
Fri, 1 Mar 2019 20:12:37 +0000 (14:12 -0600)
Signed-off-by: Sage Weil <sage@redhat.com>
src/osdc/Objecter.cc

index 1f839cabc7a1d66bc8d197e37a4c6b96080fa70d..c0a8b9e46a2932bf49a72bb9b39d7ead54c2f4bf 100644 (file)
@@ -2485,11 +2485,13 @@ int Objecter::op_cancel(OSDSession *s, ceph_tid_t tid, int r)
     return -ENOENT;
   }
 
+#if 0
   if (s->con) {
     ldout(cct, 20) << " revoking rx buffer for " << tid
                   << " on " << s->con << dendl;
     s->con->revoke_rx_buffer(tid);
   }
+#endif
 
   ldout(cct, 10) << __func__ << " tid " << tid << " in session " << s->osd
                 << dendl;
@@ -3246,6 +3248,7 @@ void Objecter::_send_op(Op *op)
   ConnectionRef con = op->session->con;
   ceph_assert(con);
 
+#if 0
   // preallocated rx buffer?
   if (op->con) {
     ldout(cct, 20) << " revoking rx buffer for " << op->tid << " on "
@@ -3261,6 +3264,7 @@ void Objecter::_send_op(Op *op)
     op->con = con;
     op->con->post_rx_buffer(op->tid, *op->outbl);
   }
+#endif
 
   op->incarnation = op->session->incarnation;
 
@@ -3450,9 +3454,10 @@ void Objecter::handle_osd_op_reply(MOSDOpReply *m)
 
   // got data?
   if (op->outbl) {
+#if 0
     if (op->con)
       op->con->revoke_rx_buffer(op->tid);
-    m->claim_data(*op->outbl);
+#endif
     op->outbl = 0;
   }