apple/foundationdb
1
0
Fork 0
mirror of https://github.com/apple/foundationdb.git synced 2025-05-15 18:32:18 +08:00
Code Issues Packages Projects Releases Wiki Activity

Rename GetGenerationRequests metric

Browse Source
This commit is contained in:
sfc-gh-tclinkenbeard 2021-08-06 15:20:12 -07:00
parent 42a45ebfc4
commit cd8a82b1b8
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
fdbserver/ConfigNode.actor.cpp
View File

@ -111,7 +111,7 @@ class ConfigNodeImpl {
Counter setMutations; Counter setMutations;
Counter clearMutations; Counter clearMutations;
Counter getValueRequests; Counter getValueRequests;
Counter newVersionRequests; Counter getGenerationRequests;
Future<Void> logger; Future<Void> logger;
ACTOR static Future<ConfigGeneration> getGeneration(ConfigNodeImpl* self) { ACTOR static Future<ConfigGeneration> getGeneration(ConfigNodeImpl* self) {
@ -347,7 +347,7 @@ class ConfigNodeImpl {
loop { loop {
choose { choose {
when(ConfigTransactionGetGenerationRequest req = waitNext(cti->getGeneration.getFuture())) { when(ConfigTransactionGetGenerationRequest req = waitNext(cti->getGeneration.getFuture())) {
++self->newVersionRequests; ++self->getGenerationRequests;
wait(getNewGeneration(self, req)); wait(getNewGeneration(self, req));
} }
when(ConfigTransactionGetRequest req = waitNext(cti->get.getFuture())) { when(ConfigTransactionGetRequest req = waitNext(cti->get.getFuture())) {
@ -472,7 +472,7 @@ public:
failedChangeRequests("FailedChangeRequests", cc), snapshotRequests("SnapshotRequests", cc), failedChangeRequests("FailedChangeRequests", cc), snapshotRequests("SnapshotRequests", cc),
getCommittedVersionRequests("GetCommittedVersionRequests", cc), successfulCommits("SuccessfulCommits", cc), getCommittedVersionRequests("GetCommittedVersionRequests", cc), successfulCommits("SuccessfulCommits", cc),
failedCommits("FailedCommits", cc), setMutations("SetMutations", cc), clearMutations("ClearMutations", cc), failedCommits("FailedCommits", cc), setMutations("SetMutations", cc), clearMutations("ClearMutations", cc),
getValueRequests("GetValueRequests", cc), newVersionRequests("NewVersionRequests", cc) { getValueRequests("GetValueRequests", cc), getGenerationRequests("GetGenerationRequests", cc) {
logger = traceCounters("ConfigNodeMetrics", id, SERVER_KNOBS->WORKER_LOGGING_INTERVAL, &cc, "ConfigNode"); logger = traceCounters("ConfigNodeMetrics", id, SERVER_KNOBS->WORKER_LOGGING_INTERVAL, &cc, "ConfigNode");
TraceEvent(SevDebug, "StartingConfigNode", id).detail("KVStoreAlreadyExists", kvStore.exists()); TraceEvent(SevDebug, "StartingConfigNode", id).detail("KVStoreAlreadyExists", kvStore.exists());
} }