summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/oplog_buffer_blocking_queue.h
diff options
context:
space:
mode:
authorBenety Goh <benety@mongodb.com>2018-06-11 16:29:18 -0400
committerBenety Goh <benety@mongodb.com>2018-06-11 16:29:18 -0400
commit76fdcd76e8800afcbb57868fb98a7b6bcda6684c (patch)
treeb2a88b9b43f41687cd2f951583d4170502487855 /src/mongo/db/repl/oplog_buffer_blocking_queue.h
parent27b827cd2f9d6b645a7d38766fa570c33e1f3d89 (diff)
downloadmongo-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.h2
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;
};