From: Greg Farnum <greg@inktank.com>
Date: Fri, 9 May 2014 23:30:27 +0000 (-0700)
Subject: Server: mark events when journaling and replying
X-Git-Tag: v0.82~82^2~4
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=2df68b6b73ad234b9c8a82511dae046f1e2aedd0;p=ceph.git

Server: mark events when journaling and replying

Signed-off-by: Greg Farnum <greg@inktank.com>
---

diff --git a/src/mds/Server.cc b/src/mds/Server.cc
index 251ae4f371a..7621652d473 100644
--- a/src/mds/Server.cc
+++ b/src/mds/Server.cc
@@ -797,6 +797,7 @@ void Server::journal_and_reply(MDRequestRef& mdr, CInode *in, CDentry *dn, LogEv
   early_reply(mdr, in, dn);
   
   mdr->committing = true;
+  mdr->mark_event("submitting journal entry");
   mdlog->submit_entry(le, fin);
   
   if (mdr->client_request && mdr->client_request->is_replay()) {
@@ -882,6 +883,8 @@ void Server::early_reply(MDRequestRef& mdr, CInode *tracei, CDentry *tracedn)
   utime_t lat = ceph_clock_now(g_ceph_context) - mdr->client_request->get_recv_stamp();
   mds->logger->tinc(l_mds_replyl, lat);
   dout(20) << "lat " << lat << dendl;
+
+  mdr->mark_event("early_replied");
 }
 
 /*
@@ -898,6 +901,8 @@ void Server::reply_request(MDRequestRef& mdr, MClientReply *reply, CInode *trace
 	   << " (" << cpp_strerror(reply->get_result())
 	   << ") " << *req << dendl;
 
+  mdr->mark_event("replying");
+
   // note successful request in session map?
   if (req->may_write() && mdr->session && reply->get_result() == 0)
     mdr->session->add_completed_request(mdr->reqid.tid, mdr->alloc_ino);