SERVER-24560 replaced references to BlockingQueue in BackgroundSync with OplogBuffer

BackgroundSync now accepts an OplogBuffer at construction

1 files changed, 28 insertions, 0 deletions

diff --git a/src/mongo/db/repl/oplog_buffer_blocking_queue.cpp b/src/mongo/db/repl/oplog_buffer_blocking_queue.cpp
index ffa01bfd2c4..ff575cae145 100644
--- a/src/mongo/db/repl/oplog_buffer_blocking_queue.cpp
+++ b/src/mongo/db/repl/oplog_buffer_blocking_queue.cpp
@@ -53,6 +53,14 @@ void OplogBufferBlockingQueue::shutdown() {
     clear();
 }
 
+void OplogBufferBlockingQueue::pushEvenIfFull(const Value& value) {
+    _queue.pushEvenIfFull(value);
+}
+
+void OplogBufferBlockingQueue::push(const Value& value) {
+    _queue.push(value);
+}
+
 bool OplogBufferBlockingQueue::pushAllNonBlocking(Batch::const_iterator begin,
                                                   Batch::const_iterator end) {
     _queue.pushAllNonBlocking(begin, end);
@@ -63,6 +71,14 @@ void OplogBufferBlockingQueue::waitForSpace(std::size_t size) {
     _queue.waitForSpace(size);
 }
 
+bool OplogBufferBlockingQueue::isEmpty() const {
+    return _queue.empty();
+}
+
+std::size_t OplogBufferBlockingQueue::getMaxSize() const {
+    return kOplogBufferSize;
+}
+
 std::size_t OplogBufferBlockingQueue::getSize() const {
     return _queue.size();
 }
@@ -79,9 +95,21 @@ bool OplogBufferBlockingQueue::tryPop(Value* value) {
     return _queue.tryPop(*value);
 }
 
+OplogBuffer::Value OplogBufferBlockingQueue::blockingPop() {
+    return _queue.blockingPop();
+}
+
+bool OplogBufferBlockingQueue::blockingPeek(Value* value, Seconds waitDuration) {
+    return _queue.blockingPeek(*value, static_cast<int>(durationCount<Seconds>(waitDuration)));
+}
+
 bool OplogBufferBlockingQueue::peek(Value* value) {
     return _queue.peek(*value);
 }
 
+boost::optional<OplogBuffer::Value> OplogBufferBlockingQueue::lastObjectPushed() const {
+    return _queue.lastObjectPushed();
+}
+
 }  // namespace repl
 }  // namespace mongo