summaryrefslogtreecommitdiff
path: root/src/mongo/dbtests/repltests.cpp
diff options
context:
space:
mode:
authorHenrik Edin <henrik.edin@mongodb.com>2018-09-17 13:35:41 -0400
committerHenrik Edin <henrik.edin@mongodb.com>2018-09-20 10:58:42 -0400
commitc69ec130f14953056461cf40ddf368d8ecf7185b (patch)
tree70fc2276ec7619c498c833fc8546fc3fd21ba558 /src/mongo/dbtests/repltests.cpp
parentd5c17e385f543f0afdc4acd5331cc5514549981f (diff)
downloadmongo-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.cpp4
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);