summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/mongo/db/storage/wiredtiger/wiredtiger_kv_engine.cpp6
-rw-r--r--src/mongo/db/storage/wiredtiger/wiredtiger_kv_engine.h2
2 files changed, 4 insertions, 4 deletions
diff --git a/src/mongo/db/storage/wiredtiger/wiredtiger_kv_engine.cpp b/src/mongo/db/storage/wiredtiger/wiredtiger_kv_engine.cpp
index 8792ae37f9c..8371d6e312a 100644
--- a/src/mongo/db/storage/wiredtiger/wiredtiger_kv_engine.cpp
+++ b/src/mongo/db/storage/wiredtiger/wiredtiger_kv_engine.cpp
@@ -343,7 +343,7 @@ WiredTigerKVEngine::WiredTigerKVEngine(const std::string& canonicalName,
}
}
- _previousCheckedDropsQueued = _clockSource->now();
+ _previousCheckedDropsQueued.store(_clockSource->now().toMillisSinceEpoch());
std::stringstream ss;
ss << "create,";
@@ -1726,7 +1726,7 @@ std::list<WiredTigerCachedCursor> WiredTigerKVEngine::filterCursorsWithQueuedDro
bool WiredTigerKVEngine::haveDropsQueued() const {
Date_t now = _clockSource->now();
- Milliseconds delta = now - _previousCheckedDropsQueued;
+ Milliseconds delta = now - Date_t::fromMillisSinceEpoch(_previousCheckedDropsQueued.load());
if (!_readOnly && _sizeStorerSyncTracker.intervalHasElapsed()) {
_sizeStorerSyncTracker.resetLastTime();
@@ -1737,7 +1737,7 @@ bool WiredTigerKVEngine::haveDropsQueued() const {
if (delta < Milliseconds(1000))
return false;
- _previousCheckedDropsQueued = now;
+ _previousCheckedDropsQueued.store(now.toMillisSinceEpoch());
// Don't wait for the mutex: if we can't get it, report that no drops are queued.
stdx::unique_lock<Latch> lk(_identToDropMutex, stdx::defer_lock);
diff --git a/src/mongo/db/storage/wiredtiger/wiredtiger_kv_engine.h b/src/mongo/db/storage/wiredtiger/wiredtiger_kv_engine.h
index 9b43d48ee83..cede3f05788 100644
--- a/src/mongo/db/storage/wiredtiger/wiredtiger_kv_engine.h
+++ b/src/mongo/db/storage/wiredtiger/wiredtiger_kv_engine.h
@@ -464,7 +464,7 @@ private:
mutable Mutex _identToDropMutex = MONGO_MAKE_LATCH("WiredTigerKVEngine::_identToDropMutex");
std::list<IdentToDrop> _identToDrop;
- mutable Date_t _previousCheckedDropsQueued;
+ mutable AtomicWord<long long> _previousCheckedDropsQueued;
std::unique_ptr<WiredTigerSession> _backupSession;
WiredTigerBackup _wtBackup;