summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/op_observer_sharding_impl.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/s/op_observer_sharding_impl.cpp')
-rw-r--r--src/mongo/db/s/op_observer_sharding_impl.cpp3
1 files changed, 2 insertions, 1 deletions
diff --git a/src/mongo/db/s/op_observer_sharding_impl.cpp b/src/mongo/db/s/op_observer_sharding_impl.cpp
index 4c72cd0e30e..493a131a9d2 100644
--- a/src/mongo/db/s/op_observer_sharding_impl.cpp
+++ b/src/mongo/db/s/op_observer_sharding_impl.cpp
@@ -226,12 +226,13 @@ void OpObserverShardingImpl::shardObserveTransactionPrepareOrUnpreparedCommit(
void OpObserverShardingImpl::shardObserveNonPrimaryTransactionPrepare(
OperationContext* opCtx,
+ const LogicalSessionId& lsid,
const std::vector<repl::OplogEntry>& stmts,
const repl::OpTime& prepareOrCommitOptime) {
opCtx->recoveryUnit()->registerChange(
std::make_unique<LogTransactionOperationsForShardingHandler>(
- *opCtx->getLogicalSessionId(), stmts, prepareOrCommitOptime));
+ lsid, stmts, prepareOrCommitOptime));
}
} // namespace mongo