]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
perfcounters: fix users of fset on averages
authorGreg Farnum <gregory.farnum@dreamhost.com>
Wed, 9 Nov 2011 19:03:48 +0000 (11:03 -0800)
committerGreg Farnum <gregory.farnum@dreamhost.com>
Wed, 9 Nov 2011 19:03:48 +0000 (11:03 -0800)
I forgot to audit these before merging the assert and they popped up
in teuthology and stuff. :(

Signed-off-by: Greg Farnum <gregory.farnum@dreamhost.com>
src/mds/Server.cc
src/osd/ReplicatedPG.cc
src/osdc/Journaler.cc

index b4926b9cea877bdeb7516d9485de280d1bded221..a9ef64f32edfbe843db2acc44ae82200562a9085 100644 (file)
@@ -822,7 +822,7 @@ void Server::early_reply(MDRequest *mdr, CInode *tracei, CDentry *tracedn)
 
   mds->logger->inc(l_mds_reply);
   double lat = ceph_clock_now(g_ceph_context) - mdr->client_request->get_recv_stamp();
-  mds->logger->fset(l_mds_replyl, lat);
+  mds->logger->finc(l_mds_replyl, lat);
   dout(20) << "lat " << lat << dendl;
 }
 
@@ -864,7 +864,7 @@ void Server::reply_request(MDRequest *mdr, MClientReply *reply, CInode *tracei,
 
     mds->logger->inc(l_mds_reply);
     double lat = ceph_clock_now(g_ceph_context) - mdr->client_request->get_recv_stamp();
-    mds->logger->fset(l_mds_replyl, lat);
+    mds->logger->finc(l_mds_replyl, lat);
     dout(20) << "lat " << lat << dendl;
     
     if (tracei)
index d619ba4939eba11f33207a6a093abd4519c3ad4a..3ed552b5465df2c7df43aaa919452937034bdfc8 100644 (file)
@@ -754,11 +754,11 @@ void ReplicatedPG::log_subop_stats(MOSDSubOp *op, int tag_inb, int tag_lat)
   osd->logger->inc(l_osd_sop);
 
   osd->logger->inc(l_osd_sop_inb, inb);
-  osd->logger->fset(l_osd_sop_lat, latency);
+  osd->logger->finc(l_osd_sop_lat, latency);
 
   if (tag_inb)
     osd->logger->inc(tag_inb, inb);
-  osd->logger->fset(tag_lat, latency);
+  osd->logger->finc(tag_lat, latency);
 
   dout(15) << "log_subop_stats " << *op << " inb " << inb << " latency " << latency << dendl;
 }
index f61951cc6b50d98c6bfa56ebbb2bd51b5baa47d0..c53a74fd3238ef0d907e94e2088d27533b65b1fe 100644 (file)
@@ -395,7 +395,7 @@ void Journaler::_finish_flush(int r, uint64_t start, utime_t stamp)
   if (logger) {
     utime_t lat = ceph_clock_now(cct);
     lat -= stamp;
-    logger->fset(logger_key_lat, lat);
+    logger->finc(logger_key_lat, lat);
   }
 
   // adjust safe_pos