summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/storage_interface.h
diff options
context:
space:
mode:
authorEric Milkie <milkie@10gen.com>2017-08-28 13:01:44 -0400
committerEric Milkie <milkie@10gen.com>2017-08-29 08:39:27 -0400
commita3547120b5ee06bfb495426f476a73703d089cc2 (patch)
tree08c25e8d7620f1b9fa7e1887cf8cd16df833aca4 /src/mongo/db/repl/storage_interface.h
parent02120b0285cdb0a0a3ac2c2b69160193b9940206 (diff)
downloadmongo-a3547120b5ee06bfb495426f476a73703d089cc2.tar.gz
SERVER-30865 Synchronize a node's initial sync writes to the oplog with its lastApplied value
Diffstat (limited to 'src/mongo/db/repl/storage_interface.h')
-rw-r--r--src/mongo/db/repl/storage_interface.h7
1 files changed, 7 insertions, 0 deletions
diff --git a/src/mongo/db/repl/storage_interface.h b/src/mongo/db/repl/storage_interface.h
index 27507e790e8..840b40e2c16 100644
--- a/src/mongo/db/repl/storage_interface.h
+++ b/src/mongo/db/repl/storage_interface.h
@@ -305,6 +305,13 @@ public:
* The 'stable' timestamp is set by calling StorageInterface::setStableTimestamp.
*/
virtual Status recoverToStableTimestamp(ServiceContext* serviceCtx) = 0;
+
+ /**
+ * Waits for oplog writes to be visible in the oplog.
+ * This function is used to ensure tests do not fail due to initial sync receiving an empty
+ * batch.
+ */
+ virtual void waitForAllEarlierOplogWritesToBeVisible(OperationContext* opCtx) = 0;
};
} // namespace repl