From c4049033d965b1c1e72d95a123472e0179ac1f56 Mon Sep 17 00:00:00 2001 From: haodong Date: Fri, 17 Jun 2016 11:56:58 +0800 Subject: [PATCH] RocksDB: add perfcounter for submit_transaction_sync operation Signed-off-by: Haodong Tang --- src/kv/RocksDBStore.cc | 21 +++++++++++---------- src/kv/RocksDBStore.h | 1 + 2 files changed, 12 insertions(+), 10 deletions(-) diff --git a/src/kv/RocksDBStore.cc b/src/kv/RocksDBStore.cc index a9cb9f37d3e..e88d43eb034 100644 --- a/src/kv/RocksDBStore.cc +++ b/src/kv/RocksDBStore.cc @@ -296,15 +296,16 @@ int RocksDBStore::do_open(ostream &out, bool create_if_missing) } PerfCountersBuilder plb(g_ceph_context, "rocksdb", l_rocksdb_first, l_rocksdb_last); - plb.add_u64_counter(l_rocksdb_gets, "rocksdb_get", "Gets"); - plb.add_u64_counter(l_rocksdb_txns, "rocksdb_transaction", "Transactions"); - plb.add_time_avg(l_rocksdb_get_latency, "rocksdb_get_latency", "Get latency"); - plb.add_time_avg(l_rocksdb_submit_latency, "rocksdb_submit_latency", "Submit Latency"); - plb.add_time_avg(l_rocksdb_submit_sync_latency, "rocksdb_submit_sync_latency", "Submit Sync Latency"); - plb.add_u64_counter(l_rocksdb_compact, "rocksdb_compact", "Compactions"); - plb.add_u64_counter(l_rocksdb_compact_range, "rocksdb_compact_range", "Compactions by range"); - plb.add_u64_counter(l_rocksdb_compact_queue_merge, "rocksdb_compact_queue_merge", "Mergings of ranges in compaction queue"); - plb.add_u64(l_rocksdb_compact_queue_len, "rocksdb_compact_queue_len", "Length of compaction queue"); + plb.add_u64_counter(l_rocksdb_gets, "get", "Gets"); + plb.add_u64_counter(l_rocksdb_txns, "submit_transaction", "Submit transactions"); + plb.add_u64_counter(l_rocksdb_txns_sync, "submit_transaction_sync", "Submit transactions sync"); + plb.add_time_avg(l_rocksdb_get_latency, "get_latency", "Get latency"); + plb.add_time_avg(l_rocksdb_submit_latency, "submit_latency", "Submit Latency"); + plb.add_time_avg(l_rocksdb_submit_sync_latency, "submit_sync_latency", "Submit Sync Latency"); + plb.add_u64_counter(l_rocksdb_compact, "compact", "Compactions"); + plb.add_u64_counter(l_rocksdb_compact_range, "compact_range", "Compactions by range"); + plb.add_u64_counter(l_rocksdb_compact_queue_merge, "compact_queue_merge", "Mergings of ranges in compaction queue"); + plb.add_u64(l_rocksdb_compact_queue_len, "compact_queue_len", "Length of compaction queue"); logger = plb.create_perf_counters(); cct->get_perfcounters_collection()->add(logger); @@ -382,7 +383,7 @@ int RocksDBStore::submit_transaction_sync(KeyValueDB::Transaction t) woptions.disableWAL = disableWAL; rocksdb::Status s = db->Write(woptions, _t->bat); utime_t lat = ceph_clock_now(g_ceph_context) - start; - logger->inc(l_rocksdb_txns); + logger->inc(l_rocksdb_txns_sync); logger->tinc(l_rocksdb_submit_sync_latency, lat); return s.ok() ? 0 : -1; } diff --git a/src/kv/RocksDBStore.h b/src/kv/RocksDBStore.h index 4953ac0d02e..c2d0455262c 100644 --- a/src/kv/RocksDBStore.h +++ b/src/kv/RocksDBStore.h @@ -26,6 +26,7 @@ enum { l_rocksdb_first = 34300, l_rocksdb_gets, l_rocksdb_txns, + l_rocksdb_txns_sync, l_rocksdb_get_latency, l_rocksdb_submit_latency, l_rocksdb_submit_sync_latency,