diff options
| author | Henrik Edin <henrik.edin@mongodb.com> | 2018-09-17 13:35:41 -0400 |
|---|---|---|
| committer | Henrik Edin <henrik.edin@mongodb.com> | 2018-09-20 10:58:42 -0400 |
| commit | c69ec130f14953056461cf40ddf368d8ecf7185b (patch) | |
| tree | 70fc2276ec7619c498c833fc8546fc3fd21ba558 /src/mongo/db/db.cpp | |
| parent | d5c17e385f543f0afdc4acd5331cc5514549981f (diff) | |
| download | mongo-c69ec130f14953056461cf40ddf368d8ecf7185b.tar.gz | |
SERVER-36084 Remove sharding runtime dependency from OpObserverImpl
Implement a new subclass of OpObserverImpl to handle the sharding logic.
Can hopefully be a pure subclass of just OpObserver when OpTimes can be passed into observers.
Diffstat (limited to 'src/mongo/db/db.cpp')
| -rw-r--r-- | src/mongo/db/db.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/mongo/db/db.cpp b/src/mongo/db/db.cpp index 7e531cd2cf7..06ce7d6787b 100644 --- a/src/mongo/db/db.cpp +++ b/src/mongo/db/db.cpp @@ -91,7 +91,6 @@ #include "mongo/db/logical_time_metadata_hook.h" #include "mongo/db/logical_time_validator.h" #include "mongo/db/mongod_options.h" -#include "mongo/db/op_observer_impl.h" #include "mongo/db/op_observer_registry.h" #include "mongo/db/operation_context.h" #include "mongo/db/periodic_runner_job_abort_expired_transactions.h" @@ -112,6 +111,7 @@ #include "mongo/db/s/balancer/balancer.h" #include "mongo/db/s/config/sharding_catalog_manager.h" #include "mongo/db/s/config_server_op_observer.h" +#include "mongo/db/s/op_observer_sharding_impl.h" #include "mongo/db/s/shard_server_op_observer.h" #include "mongo/db/s/sharding_initialization_mongod.h" #include "mongo/db/s/sharding_state_recovery.h" @@ -281,7 +281,7 @@ ExitCode _initAndListen(int listenPort) { serviceContext->setFastClockSource(FastClockSourceFactory::create(Milliseconds(10))); auto opObserverRegistry = stdx::make_unique<OpObserverRegistry>(); - opObserverRegistry->addObserver(stdx::make_unique<OpObserverImpl>()); + opObserverRegistry->addObserver(stdx::make_unique<OpObserverShardingImpl>()); opObserverRegistry->addObserver(stdx::make_unique<UUIDCatalogObserver>()); if (serverGlobalParams.clusterRole == ClusterRole::ShardServer) { |