]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
osd: set reqid for push/pull subops
authorSage Weil <sage@newdream.net>
Wed, 27 Jan 2010 19:33:11 +0000 (11:33 -0800)
committerSage Weil <sage@newdream.net>
Wed, 27 Jan 2010 19:33:11 +0000 (11:33 -0800)
This just makes tracking down requests in the debug output easier.

src/osd/ReplicatedPG.cc

index 60513ddf7884da8f47a04aa2328770a6e0e56549..fc0b8659130d7c9d89f084d15165b7b1963ed0b0 100644 (file)
@@ -2770,9 +2770,10 @@ bool ReplicatedPG::pull(const sobject_t& soid)
 
   // send op
   osd_reqid_t rid;
-  tid_t tid = osd->get_tid();
+  rid.name = entity_name_t::OSD(osd->whoami);
+  rid.tid = osd->get_tid();
   MOSDSubOp *subop = new MOSDSubOp(rid, info.pgid, soid, false, CEPH_OSD_FLAG_ACK,
-                                  osd->osdmap->get_epoch(), tid, v);
+                                  osd->osdmap->get_epoch(), rid.tid, v);
   subop->ops = vector<OSDOp>(1);
   subop->ops[0].op.op = CEPH_OSD_OP_PULL;
   subop->data_subset.swap(data_subset);
@@ -2913,9 +2914,11 @@ void ReplicatedPG::push(const sobject_t& soid, int peer,
   osd->logger->inc(l_osd_r_pushb, bl.length());
   
   // send
-  osd_reqid_t rid;  // useless?
+  osd_reqid_t rid;
+  rid.name = entity_name_t::OSD(osd->whoami);
+  rid.tid = osd->get_tid();
   MOSDSubOp *subop = new MOSDSubOp(rid, info.pgid, soid, false, 0,
-                                  osd->osdmap->get_epoch(), osd->get_tid(), oi.version);
+                                  osd->osdmap->get_epoch(), rid.tid, oi.version);
   subop->ops = vector<OSDOp>(1);
   subop->ops[0].op.op = CEPH_OSD_OP_PUSH;
   subop->ops[0].op.extent.offset = 0;