]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
Server: use req directly 9706/head
authorxie xingguo <xie.xingguo@zte.com.cn>
Wed, 15 Jun 2016 02:42:19 +0000 (10:42 +0800)
committerxie xingguo <xie.xingguo@zte.com.cn>
Wed, 15 Jun 2016 03:40:37 +0000 (11:40 +0800)
We have req pointed to mdr->client_request already, so use
it directly to keep the bothering of a long dereference series of
pointer(which also results in a longer line) away.

Signed-off-by: xie xingguo <xie.xingguo@zte.com.cn>
src/mds/Server.cc

index b6407b2b9b6592111ebc846cfcd5659c2f1cb029..9ad51c924bb57af79d48243f8527345c44d6577e 100644 (file)
@@ -1062,7 +1062,7 @@ void Server::early_reply(MDRequestRef& mdr, CInode *tracei, CDentry *tracedn)
   }
 
 
-  MClientReply *reply = new MClientReply(mdr->client_request, 0);
+  MClientReply *reply = new MClientReply(req, 0);
   reply->set_unsafe();
 
   // mark xlocks "done", indicating that we are exposing uncommitted changes.
@@ -1070,7 +1070,7 @@ void Server::early_reply(MDRequestRef& mdr, CInode *tracei, CDentry *tracedn)
   //_rename_finish() does not send dentry link/unlink message to replicas.
   // so do not set xlocks on dentries "done", the xlocks prevent dentries
   // that have projected linkages from getting new replica.
-  mds->locker->set_xlocks_done(mdr.get(), mdr->client_request->get_op() == CEPH_MDS_OP_RENAME);
+  mds->locker->set_xlocks_done(mdr.get(), req->get_op() == CEPH_MDS_OP_RENAME);
 
   dout(10) << "early_reply " << reply->get_result() 
           << " (" << cpp_strerror(reply->get_result())
@@ -1083,8 +1083,7 @@ void Server::early_reply(MDRequestRef& mdr, CInode *tracei, CDentry *tracedn)
       mdr->cap_releases.erase(tracedn->get_dir()->get_inode()->vino());
 
     set_trace_dist(mdr->session, reply, tracei, tracedn, mdr->snapid,
-                  mdr->client_request->get_dentry_wanted(),
-                  mdr);
+                  req->get_dentry_wanted(), mdr);
   }
 
   reply->set_extra_bl(mdr->reply_extra_bl);
@@ -1093,7 +1092,7 @@ void Server::early_reply(MDRequestRef& mdr, CInode *tracei, CDentry *tracedn)
   mdr->did_early_reply = true;
 
   mds->logger->inc(l_mds_reply);
-  utime_t lat = ceph_clock_now(g_ceph_context) - mdr->client_request->get_recv_stamp();
+  utime_t lat = ceph_clock_now(g_ceph_context) - req->get_recv_stamp();
   mds->logger->tinc(l_mds_reply_latency, lat);
   dout(20) << "lat " << lat << dendl;
 
@@ -2725,7 +2724,7 @@ void Server::handle_client_getattr(MDRequestRef& mdr, bool is_lookup)
   mdr->getattr_caps = mask;
 
   mds->balancer->hit_inode(ceph_clock_now(g_ceph_context), ref, META_POP_IRD,
-                          mdr->client_request->get_source().num());
+                          req->get_source().num());
 
   // reply
   dout(10) << "reply to stat on " << *req << dendl;