]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
mon: Monitor: mark events
authorJoao Eduardo Luis <joao@suse.de>
Fri, 5 Jun 2015 15:11:57 +0000 (16:11 +0100)
committerJoao Eduardo Luis <joao@suse.de>
Thu, 16 Jul 2015 17:06:07 +0000 (18:06 +0100)
Signed-off-by: Joao Eduardo Luis <joao@suse.de>
src/mon/Monitor.cc

index fc6ce68a5134f446ca374da906e42a64552a1d33..ec90ad8b76f74f298e4392c71fee2500b492697a 100644 (file)
@@ -3380,9 +3380,11 @@ void Monitor::waitlist_or_zap_client(MonOpRequestRef op)
       con->is_connected()) {
     dout(5) << "waitlisting message " << *m << dendl;
     maybe_wait_for_quorum.push_back(new C_RetryMessage(this, op));
+    op->mark_wait_for_quorum();
   } else {
     dout(5) << "discarding message " << *m << " and sending client elsewhere" << dendl;
     con->mark_down();
+    op->mark_zap();
   }
 }
 
@@ -3398,6 +3400,7 @@ void Monitor::_ms_dispatch(Message *m)
 
 void Monitor::dispatch(MonOpRequestRef op)
 {
+  op->mark_event("monitor_dispatch");
   ConnectionRef connection = op->get_connection();
   MonSession *s = NULL;
   MonCap caps;
@@ -3486,6 +3489,7 @@ void Monitor::dispatch(MonOpRequestRef op)
 
 void Monitor::dispatch_op(MonOpRequestRef op)
 {
+  op->mark_event("monitor_dispatch_op");
   /* deal with all messages that do not necessarily need caps */
   bool dealt_with = true;
   switch (op->get_req()->get_type()) {