]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
osd: debug pg mode
authorSage Weil <sage@newdream.net>
Tue, 17 Nov 2009 23:22:27 +0000 (15:22 -0800)
committerSage Weil <sage@newdream.net>
Wed, 18 Nov 2009 00:30:39 +0000 (16:30 -0800)
src/osd/ReplicatedPG.cc

index 85c91ef1c196fe921f6f34b89b945ee59dd928a1..ea88fab7a57833e9ce5c975c18eb6dcbc2206503 100644 (file)
@@ -486,6 +486,7 @@ void ReplicatedPG::do_op(MOSDOp *op)
   }    
   
   bool ok;
+  dout(10) << "do_op mode is " << mode << dendl;
   if (op->may_read() && op->may_write())
     ok = mode.try_rmw(client);
   else if (op->may_write())
@@ -506,7 +507,7 @@ void ReplicatedPG::do_op(MOSDOp *op)
     return;
   }
 
-  dout(10) << "mode now " << mode << dendl;
+  dout(10) << "do_op mode now " << mode << dendl;
 
   const sobject_t& soid = obc->obs.oi.soid;
   OpContext *ctx = new OpContext(op, op->get_reqid(), op->ops, op->get_data(),
@@ -1871,8 +1872,9 @@ void ReplicatedPG::apply_repop(RepGather *repop)
     repop->ctx->clone_obc = 0;
   }
 
+  dout(10) << "apply_repop mode was " << mode << dendl;
   mode.finish_write();
-  dout(10) << "mode now " << mode << dendl;
+  dout(10) << "apply_repop mode now " << mode << " (finish_write)" << dendl;
 
   put_object_context(repop->obc);
   repop->obc = 0;
@@ -2028,9 +2030,10 @@ ReplicatedPG::RepGather *ReplicatedPG::new_repop(OpContext *ctx, ObjectContext *
 
   RepGather *repop = new RepGather(ctx, obc, noop, rep_tid, info.last_complete);
 
+  dout(10) << "new_repop mode was " << mode << dendl;
   mode.start_write();
   obc->get();  // we take a ref
-  dout(10) << "mode now " << mode << dendl;
+  dout(10) << "new_repop mode now " << mode << " (start_write)" << dendl;
 
   // initialize gather sets
   for (unsigned i=0; i<acting.size(); i++) {