import 15.2.0 Octopus source

[ceph.git] / ceph / src / mds / SnapClient.cc

diff --git a/ceph/src/mds/SnapClient.cc b/ceph/src/mds/SnapClient.cc
index fa1f56b4c35eeb03f021aa06f1f3b1e43b5d41fd..7ddf1e7c8af650a59dd9926b9431d06c6cf7e20b 100644 (file)
--- a/ceph/src/mds/SnapClient.cc
+++ b/ceph/src/mds/SnapClient.cc
@@ -40,7 +40,7 @@ void SnapClient::resend_queries()
   }
 }
 
-void SnapClient::handle_query_result(const MMDSTableRequest::const_ref &m)
+void SnapClient::handle_query_result(const cref_t<MMDSTableRequest> &m)
 {
   dout(10) << __func__ << " " << *m << dendl;
 
@@ -111,11 +111,11 @@ void SnapClient::handle_query_result(const MMDSTableRequest::const_ref &m)
   }
 }
 
-void SnapClient::handle_notify_prep(const MMDSTableRequest::const_ref &m)
+void SnapClient::handle_notify_prep(const cref_t<MMDSTableRequest> &m)
 {
   dout(10) << __func__ << " " << *m << dendl;
   handle_query_result(m);
-  auto ack = MMDSTableRequest::create(table, TABLESERVER_OP_NOTIFY_ACK, 0, m->get_tid());
+  auto ack = make_message<MMDSTableRequest>(table, TABLESERVER_OP_NOTIFY_ACK, 0, m->get_tid());
   mds->send_message(ack, m->get_connection());
 }
 
@@ -153,7 +153,7 @@ void SnapClient::refresh(version_t want, MDSContext *onfinish)
     return;
 
   mds_rank_t ts = mds->mdsmap->get_tableserver();
-  auto req = MMDSTableRequest::create(table, TABLESERVER_OP_QUERY, ++last_reqid, 0);
+  auto req = make_message<MMDSTableRequest>(table, TABLESERVER_OP_QUERY, ++last_reqid, 0);
   using ceph::encode;
   char op = 'F';
   encode(op, req->bl);