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/dbtests/repltests.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/dbtests/repltests.cpp')
-rw-r--r-- | src/mongo/dbtests/repltests.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/mongo/dbtests/repltests.cpp b/src/mongo/dbtests/repltests.cpp index 662f6c8430e..a2d6e66b2c7 100644 --- a/src/mongo/dbtests/repltests.cpp +++ b/src/mongo/dbtests/repltests.cpp @@ -43,13 +43,13 @@ #include "mongo/db/db_raii.h" #include "mongo/db/dbdirectclient.h" #include "mongo/db/json.h" -#include "mongo/db/op_observer_impl.h" #include "mongo/db/ops/update.h" #include "mongo/db/repl/oplog.h" #include "mongo/db/repl/repl_client_info.h" #include "mongo/db/repl/replication_coordinator.h" #include "mongo/db/repl/replication_coordinator_mock.h" #include "mongo/db/repl/sync_tail.h" +#include "mongo/db/s/op_observer_sharding_impl.h" #include "mongo/dbtests/dbtests.h" #include "mongo/transport/transport_layer_asio.h" #include "mongo/util/log.h" @@ -133,7 +133,7 @@ public: // to avoid the invariant in ReplClientInfo::setLastOp that the optime only goes forward. repl::ReplClientInfo::forClient(_opCtx.getClient()).clearLastOp_forTest(); - getGlobalServiceContext()->setOpObserver(stdx::make_unique<OpObserverImpl>()); + getGlobalServiceContext()->setOpObserver(stdx::make_unique<OpObserverShardingImpl>()); setOplogCollectionName(getGlobalServiceContext()); createOplog(&_opCtx); |