summaryrefslogtreecommitdiff
path: root/src/mongo/db/op_observer/oplog_writer_impl.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/op_observer/oplog_writer_impl.cpp')
-rw-r--r--src/mongo/db/op_observer/oplog_writer_impl.cpp8
1 files changed, 1 insertions, 7 deletions
diff --git a/src/mongo/db/op_observer/oplog_writer_impl.cpp b/src/mongo/db/op_observer/oplog_writer_impl.cpp
index 6c272491f5b..23615bf9722 100644
--- a/src/mongo/db/op_observer/oplog_writer_impl.cpp
+++ b/src/mongo/db/op_observer/oplog_writer_impl.cpp
@@ -48,14 +48,8 @@ std::vector<repl::OpTime> OplogWriterImpl::logInsertOps(
std::vector<bool> fromMigrate,
const ShardingWriteRouter& shardingWriteRouter,
const CollectionPtr& collectionPtr) {
-
- std::function<boost::optional<ShardId>(const BSONObj& doc)> getDestinedRecipientFn =
- [&shardingWriteRouter](const BSONObj& doc) {
- return shardingWriteRouter.getReshardingDestinedRecipient(doc);
- };
-
return repl::logInsertOps(
- opCtx, oplogEntryTemplate, begin, end, fromMigrate, getDestinedRecipientFn, collectionPtr);
+ opCtx, oplogEntryTemplate, begin, end, fromMigrate, shardingWriteRouter, collectionPtr);
}
repl::OpTime OplogWriterImpl::logOp(OperationContext* opCtx, repl::MutableOplogEntry* oplogEntry) {