RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-02-06 02:14:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

osd: debug msg prio, cost, latency

Browse Source 
Signed-off-by: Sage Weil <sage@inktank.com>
This commit is contained in:
Sage Weil 2013-01-21 13:25:21 -08:00
parent 40654d6d53
commit bec96a234c
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/osd/OSD.cc
View File

@ -6040,7 +6040,11 @@ bool OSD::op_is_discardable(MOSDOp *op)
*/
void OSD::enqueue_op(PG *pg, OpRequestRef op)
{
dout(15) << "enqueue_op " << op << " " << *(op->request) << dendl;
utime_t latency = ceph_clock_now(g_ceph_context) - op->request->get_recv_stamp();
dout(15) << "enqueue_op " << op << " prio " << op->request->get_priority()
<< " cost " << op->request->get_data().length()
<< " latency " << latency
<< " " << *(op->request) << dendl;
op_wq.queue(make_pair(PGRef(pg), op));
}
@ -6125,7 +6129,11 @@ void OSDService::dequeue_pg(PG *pg, list<OpRequestRef> *dequeued)
*/
void OSD::dequeue_op(PGRef pg, OpRequestRef op)
{
dout(10) << "dequeue_op " << op << " " << *(op->request)
utime_t latency = ceph_clock_now(g_ceph_context) - op->request->get_recv_stamp();
dout(10) << "dequeue_op " << op << " prio " << op->request->get_priority()
<< " cost " << op->request->get_data().length()
<< " latency " << latency
<< " " << *(op->request)
<< " pg " << *pg << dendl;
if (pg->deleting)
return;