diff options
author | Benety Goh <benety@mongodb.com> | 2018-06-11 16:29:18 -0400 |
---|---|---|
committer | Benety Goh <benety@mongodb.com> | 2018-06-11 16:29:18 -0400 |
commit | 76fdcd76e8800afcbb57868fb98a7b6bcda6684c (patch) | |
tree | b2a88b9b43f41687cd2f951583d4170502487855 /src/mongo/db/repl/oplog_buffer_blocking_queue.h | |
parent | 27b827cd2f9d6b645a7d38766fa570c33e1f3d89 (diff) | |
download | mongo-76fdcd76e8800afcbb57868fb98a7b6bcda6684c.tar.gz |
SERVER-33864 OplogBufferBlockingQueue supports updating optional Counters
Diffstat (limited to 'src/mongo/db/repl/oplog_buffer_blocking_queue.h')
-rw-r--r-- | src/mongo/db/repl/oplog_buffer_blocking_queue.h | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/mongo/db/repl/oplog_buffer_blocking_queue.h b/src/mongo/db/repl/oplog_buffer_blocking_queue.h index 68c74779b0e..1bd0fe5278c 100644 --- a/src/mongo/db/repl/oplog_buffer_blocking_queue.h +++ b/src/mongo/db/repl/oplog_buffer_blocking_queue.h @@ -40,6 +40,7 @@ namespace repl { class OplogBufferBlockingQueue final : public OplogBuffer { public: OplogBufferBlockingQueue(); + explicit OplogBufferBlockingQueue(Counters* counters); void startup(OperationContext* opCtx) override; void shutdown(OperationContext* opCtx) override; @@ -60,6 +61,7 @@ public: boost::optional<Value> lastObjectPushed(OperationContext* opCtx) const override; private: + Counters* const _counters; BlockingQueue<BSONObj> _queue; }; |