summaryrefslogtreecommitdiff
path: root/src/mongo/db/storage/wiredtiger/wiredtiger_oplog_manager.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/storage/wiredtiger/wiredtiger_oplog_manager.h')
-rw-r--r--src/mongo/db/storage/wiredtiger/wiredtiger_oplog_manager.h6
1 files changed, 5 insertions, 1 deletions
diff --git a/src/mongo/db/storage/wiredtiger/wiredtiger_oplog_manager.h b/src/mongo/db/storage/wiredtiger/wiredtiger_oplog_manager.h
index 435b6b31f20..819faf80907 100644
--- a/src/mongo/db/storage/wiredtiger/wiredtiger_oplog_manager.h
+++ b/src/mongo/db/storage/wiredtiger/wiredtiger_oplog_manager.h
@@ -76,7 +76,7 @@ public:
// Waits until all committed writes at this point to become visible (that is, no holes exist in
// the oplog.)
void waitForAllEarlierOplogWritesToBeVisible(const WiredTigerRecordStore* oplogRecordStore,
- OperationContext* opCtx) const;
+ OperationContext* opCtx);
// Returns the all committed timestamp. All transactions with timestamps earlier than the
// all committed timestamp are committed.
@@ -103,6 +103,10 @@ private:
RecordId _oplogMaxAtStartup = RecordId(0); // Guarded by oplogVisibilityStateMutex.
bool _opsWaitingForJournal = false; // Guarded by oplogVisibilityStateMutex.
+ // When greater than 0, indicates that there are operations waiting for oplog visibility, and
+ // journal flushing should not be delayed.
+ std::int64_t _opsWaitingForVisibility = 0; // Guarded by oplogVisibilityStateMutex.
+
AtomicUInt64 _oplogReadTimestamp;
};
} // namespace mongo