diff options
author | Benety Goh <benety@mongodb.com> | 2016-06-13 16:58:05 -0400 |
---|---|---|
committer | Benety Goh <benety@mongodb.com> | 2016-06-14 18:33:50 -0400 |
commit | 0f744edcde0011533bc2d88b04581199cfee9070 (patch) | |
tree | 58145f4fd77e93f5fa3c2efb3ebd1f348b367da6 /src/mongo/db/repl/oplog_buffer_collection.cpp | |
parent | dbbad24bfbc6d391dffe5902977431d90201db3b (diff) | |
download | mongo-0f744edcde0011533bc2d88b04581199cfee9070.tar.gz |
SERVER-24560 replaced references to BlockingQueue in BackgroundSync with OplogBuffer
BackgroundSync now accepts an OplogBuffer at construction
Diffstat (limited to 'src/mongo/db/repl/oplog_buffer_collection.cpp')
-rw-r--r-- | src/mongo/db/repl/oplog_buffer_collection.cpp | 24 |
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 |