osd: log stats for push and pull bytes

diff --git a/src/osd/OSD.cc b/src/osd/OSD.cc
index 7b1434f01b1780a676d8f1ab2ae0f14e1bbdc01e..84af7912d542ec610e32bb52929896d15fd69d26 100644 (file)
--- a/src/osd/OSD.cc
+++ b/src/osd/OSD.cc
@@ -386,10 +386,13 @@ int OSD::init()
   osd_logtype.add_inc("c_wr");
   osd_logtype.add_inc("c_wrb");
   
-  osd_logtype.add_inc("r_push");
-  osd_logtype.add_inc("r_pushb");
   osd_logtype.add_inc("r_wr");
   osd_logtype.add_inc("r_wrb");
+
+  osd_logtype.add_inc("r_push");
+  osd_logtype.add_inc("r_pushb");
+  osd_logtype.add_inc("r_pull");
+  osd_logtype.add_inc("r_pullb");
   
   osd_logtype.add_set("qlen");
   osd_logtype.add_set("rqlen");

diff --git a/src/osd/ReplicatedPG.cc b/src/osd/ReplicatedPG.cc
index 88bca852fb16cb09be9f850644e43c9919f28101..3795b65ee417da90a94bf29f8665f2aab1751710 100644 (file)
--- a/src/osd/ReplicatedPG.cc
+++ b/src/osd/ReplicatedPG.cc
@@ -2373,7 +2373,8 @@ void ReplicatedPG::sub_op_push(MOSDSubOp *op)
   unsigned r = osd->store->apply_transaction(t);
   assert(r == 0);
 
-
+  osd->logger->inc("r_pull");
+  osd->logger->inc("r_pullb", data.length());
 
   if (is_primary()) {
     if (info.is_uptodate())