diff options
| author | Samyukta Lanka <samy.lanka@mongodb.com> | 2020-02-12 23:19:35 +0000 |
|---|---|---|
| committer | evergreen <evergreen@mongodb.com> | 2020-02-12 23:19:35 +0000 |
| commit | 0a4a011397d7e399cbe93a2e2da60aec84997533 (patch) | |
| tree | f204d0c765e9ef04d11e405706b227660af5366b /src/mongo/db/repl/oplog_fetcher.h | |
| parent | 994fdd99bb6adb2cf9c7dd4061c2035188c2c8da (diff) | |
| download | mongo-0a4a011397d7e399cbe93a2e2da60aec84997533.tar.gz | |
SERVER-45470 Process metadata with each new batch in the new oplog fetcher
Diffstat (limited to 'src/mongo/db/repl/oplog_fetcher.h')
| -rw-r--r-- | src/mongo/db/repl/oplog_fetcher.h | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/src/mongo/db/repl/oplog_fetcher.h b/src/mongo/db/repl/oplog_fetcher.h index 0c64c44ede3..69af79c6c6f 100644 --- a/src/mongo/db/repl/oplog_fetcher.h +++ b/src/mongo/db/repl/oplog_fetcher.h @@ -391,7 +391,7 @@ public: /** * Prints out the status and settings of the oplog fetcher. */ - std::string toString() const; + std::string toString(); // ================== Test support API =================== @@ -481,6 +481,11 @@ private: Status _connect(); /** + * Sets the RequestMetadataWriter and ReplyMetadataReader on the connection. + */ + void _setMetadataWriterAndReader(); + + /** * Executes a `find` query on the sync source's oplog and establishes a tailable, awaitData, * exhaust cursor. * |