diff options
| author | Dianna Hohensee <dianna.hohensee@mongodb.com> | 2020-03-06 16:08:46 -0500 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2020-03-09 16:27:43 +0000 |
| commit | 0bcd8d56c22cb339faf3bf8a1bf7abd838da05ad (patch) | |
| tree | 8ce98f1643534211a8e5d2afa97ab5dd22e141df /src/mongo/db/storage | |
| parent | 6e7fe4cdbf63d49b05fd28cca93d5dc503048c77 (diff) | |
| download | mongo-0bcd8d56c22cb339faf3bf8a1bf7abd838da05ad.tar.gz | |
SERVER-46622 Disable Flow Control for the WiredTigerJournalFlusher internal thread
Diffstat (limited to 'src/mongo/db/storage')
| -rw-r--r-- | src/mongo/db/storage/wiredtiger/wiredtiger_kv_engine.cpp | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/src/mongo/db/storage/wiredtiger/wiredtiger_kv_engine.cpp b/src/mongo/db/storage/wiredtiger/wiredtiger_kv_engine.cpp index 1ded26520f8..c800de5100f 100644 --- a/src/mongo/db/storage/wiredtiger/wiredtiger_kv_engine.cpp +++ b/src/mongo/db/storage/wiredtiger/wiredtiger_kv_engine.cpp @@ -252,6 +252,11 @@ public: // Initialize the thread's opCtx. _uniqueCtx.emplace(tc->makeOperationContext()); + + // Updates to a non-replicated collection, oplogTruncateAfterPoint, are made by this thread. + // Non-replicated writes will not contribute to replication lag and can be safely excluded + // from Flow Control. + _uniqueCtx->get()->setShouldParticipateInFlowControl(false); while (true) { pauseJournalFlusherThread.pauseWhileSet(_uniqueCtx->get()); @@ -268,6 +273,7 @@ public: stdx::lock_guard<Latch> lk(_opCtxMutex); _uniqueCtx.reset(); _uniqueCtx.emplace(tc->makeOperationContext()); + _uniqueCtx->get()->setShouldParticipateInFlowControl(false); }); _sessionCache->waitUntilDurable( |