diff options
Diffstat (limited to 'src/mongo/db/repl/sync_tail.h')
-rw-r--r-- | src/mongo/db/repl/sync_tail.h | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/src/mongo/db/repl/sync_tail.h b/src/mongo/db/repl/sync_tail.h index 539a00d933d..313a16bf48b 100644 --- a/src/mongo/db/repl/sync_tail.h +++ b/src/mongo/db/repl/sync_tail.h @@ -143,6 +143,11 @@ public: return _deque.back(); } + const OplogEntry& front() const { + invariant(!_deque.empty()); + return _deque.front(); + } + private: std::deque<OplogEntry> _deque; size_t _size; @@ -194,9 +199,7 @@ protected: // Apply a batch of operations, using multiple threads. // If boundries is supplied, will update minValid document at begin and end of batch. // Returns the last OpTime applied during the apply batch, ops.end["ts"] basically. - OpTime multiApply(OperationContext* txn, - const OpQueue& ops, - boost::optional<BatchBoundaries> boundaries = {}); + OpTime multiApply(OperationContext* txn, const OpQueue& ops); private: class OpQueueBatcher; |