summaryrefslogtreecommitdiff
path: root/src/mongo/embedded
diff options
context:
space:
mode:
authorBenety Goh <benety@mongodb.com>2022-07-15 09:35:12 -0400
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2022-07-15 14:09:00 +0000
commit6b60d7b2304cf01a1ad6109d7a15b66db5889ad0 (patch)
tree6b2887227138ded79739bc26e0c37eea67a5c3b8 /src/mongo/embedded
parent3bf33a7f67667dbe5c1785c2d6a55a19cd17fb4e (diff)
downloadmongo-6b60d7b2304cf01a1ad6109d7a15b66db5889ad0.tar.gz
SERVER-67508 OpObserverImpl constructor accepts OplogWriter
Diffstat (limited to 'src/mongo/embedded')
-rw-r--r--src/mongo/embedded/embedded.cpp4
1 files changed, 3 insertions, 1 deletions
diff --git a/src/mongo/embedded/embedded.cpp b/src/mongo/embedded/embedded.cpp
index a1a5eceaaf2..d6a662076fb 100644
--- a/src/mongo/embedded/embedded.cpp
+++ b/src/mongo/embedded/embedded.cpp
@@ -63,6 +63,7 @@
#include "mongo/db/ttl.h"
#include "mongo/embedded/embedded_options_parser_init.h"
#include "mongo/embedded/index_builds_coordinator_embedded.h"
+#include "mongo/embedded/oplog_writer_embedded.h"
#include "mongo/embedded/periodic_runner_embedded.h"
#include "mongo/embedded/read_write_concern_defaults_cache_lookup_embedded.h"
#include "mongo/embedded/replication_coordinator_embedded.h"
@@ -208,7 +209,8 @@ ServiceContext* initialize(const char* yaml_config) {
serviceContext->setServiceEntryPoint(std::make_unique<ServiceEntryPointEmbedded>());
auto opObserverRegistry = std::make_unique<OpObserverRegistry>();
- opObserverRegistry->addObserver(std::make_unique<OpObserverImpl>());
+ opObserverRegistry->addObserver(
+ std::make_unique<OpObserverImpl>(std::make_unique<OplogWriterEmbedded>()));
serviceContext->setOpObserver(std::move(opObserverRegistry));
DBDirectClientFactory::get(serviceContext).registerImplementation([](OperationContext* opCtx) {