diff options
| author | Pierlauro Sciarelli <pierlauro.sciarelli@mongodb.com> | 2020-07-16 23:19:53 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2020-07-16 23:44:21 +0000 |
| commit | d760da5e25d5de81fc144e818fb612661adb4728 (patch) | |
| tree | 33eb43f8c0df473ff7c7734dde4ce9e17cd3bc2d /src/mongo/db/vector_clock_mongod.cpp | |
| parent | 550a9ee713078ec583621a0d6c368a6bc6ce43d2 (diff) | |
| download | mongo-d760da5e25d5de81fc144e818fb612661adb4728.tar.gz | |
SERVER-48717 Implement the persist/recover functionalities of the VectorClock [last additional changes]
Diffstat (limited to 'src/mongo/db/vector_clock_mongod.cpp')
| -rw-r--r-- | src/mongo/db/vector_clock_mongod.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/mongo/db/vector_clock_mongod.cpp b/src/mongo/db/vector_clock_mongod.cpp index c0c1caea299..f517dc0d945 100644 --- a/src/mongo/db/vector_clock_mongod.cpp +++ b/src/mongo/db/vector_clock_mongod.cpp @@ -239,7 +239,7 @@ private: vcd.setVectorClock(obj); store.update(opCtx, - VectorClock::kStateQuery(), + VectorClock::stateQuery(), vcd.toBSON(), WriteConcerns::kMajorityWriteConcern, true); @@ -259,14 +259,14 @@ private: NamespaceString nss(NamespaceString::kVectorClockNamespace); PersistentTaskStore<VectorClockDocument> store(nss); - int nDocuments = store.count(opCtx, VectorClock::kStateQuery()); + int nDocuments = store.count(opCtx, VectorClock::stateQuery()); if (nDocuments == 0) { LOGV2_DEBUG(4924403, 2, "No VectorClockDocument to recover"); return; } fassert(4924404, nDocuments == 1); - store.forEach(opCtx, VectorClock::kStateQuery(), [&](const VectorClockDocument& vcd) { + store.forEach(opCtx, VectorClock::stateQuery(), [&](const VectorClockDocument& vcd) { BSONObj obj = vcd.getVectorClock(); LogicalTimeArray newTime; |