mirror of
https://github.com/ceph/ceph
synced 2024-12-17 17:05:42 +00:00
Merge pull request #9770 from tanghaodong25/submit-transaction-perfcounter
kv/RocksDB: add perfcounter for submit_transaction_sync operation Reviewed-by: Sage Weil <sage@redhat.com>
This commit is contained in:
commit
125c42a452
@ -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;
|
||||
}
|
||||
|
@ -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,
|
||||
|
Loading…
Reference in New Issue
Block a user