SERVER-24560 replaced references to BlockingQueue in BackgroundSync with OplogBuffer

BackgroundSync now accepts an OplogBuffer at construction

1 files changed, 24 insertions, 0 deletions

diff --git a/src/mongo/db/repl/oplog_buffer_collection.cpp b/src/mongo/db/repl/oplog_buffer_collection.cpp
index 3c060e77443..7af1057e022 100644
--- a/src/mongo/db/repl/oplog_buffer_collection.cpp
+++ b/src/mongo/db/repl/oplog_buffer_collection.cpp
@@ -86,6 +86,10 @@ void OplogBufferCollection::startup() {
 
 void OplogBufferCollection::shutdown() {}
 
+void OplogBufferCollection::pushEvenIfFull(const Value& value) {}
+
+void OplogBufferCollection::push(const Value& value) {}
+
 bool OplogBufferCollection::pushAllNonBlocking(Batch::const_iterator begin,
                                                Batch::const_iterator end) {
     return false;
@@ -93,6 +97,14 @@ bool OplogBufferCollection::pushAllNonBlocking(Batch::const_iterator begin,
 
 void OplogBufferCollection::waitForSpace(std::size_t size) {}
 
+bool OplogBufferCollection::isEmpty() const {
+    return true;
+}
+
+std::size_t OplogBufferCollection::getMaxSize() const {
+    return 0;
+}
+
 std::size_t OplogBufferCollection::getSize() const {
     return 0;
 }
@@ -107,9 +119,21 @@ bool OplogBufferCollection::tryPop(Value* value) {
     return false;
 }
 
+OplogBuffer::Value OplogBufferCollection::blockingPop() {
+    return {};
+}
+
+bool OplogBufferCollection::blockingPeek(Value* value, Seconds waitDuration) {
+    return false;
+}
+
 bool OplogBufferCollection::peek(Value* value) {
     return false;
 }
 
+boost::optional<OplogBuffer::Value> OplogBufferCollection::lastObjectPushed() const {
+    return {};
+}
+
 }  // namespace repl
 }  // namespace mongo