diff options
author | Jason Chan <jason.chan@10gen.com> | 2019-04-08 12:55:52 -0400 |
---|---|---|
committer | Jason Chan <jason.chan@10gen.com> | 2019-04-08 13:49:56 -0400 |
commit | ac77a440f9df976234c2fe92c6726348e592ca8d (patch) | |
tree | e1bb1ad9c0b786750740d1edc7f5b152af2ccdcb /src/mongo/db/repl/sync_tail.cpp | |
parent | bfa61a6b053de26ca47b7baad7a415f5bcdfae2c (diff) | |
download | mongo-ac77a440f9df976234c2fe92c6726348e592ca8d.tar.gz |
SERVER-39793 Update the state in transaction table for running transactions on secondary
Diffstat (limited to 'src/mongo/db/repl/sync_tail.cpp')
-rw-r--r-- | src/mongo/db/repl/sync_tail.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/mongo/db/repl/sync_tail.cpp b/src/mongo/db/repl/sync_tail.cpp index 68de8ea4e39..37d270817ab 100644 --- a/src/mongo/db/repl/sync_tail.cpp +++ b/src/mongo/db/repl/sync_tail.cpp @@ -74,6 +74,7 @@ #include "mongo/db/session_txn_record_gen.h" #include "mongo/db/stats/timer_stats.h" #include "mongo/db/transaction_participant.h" +#include "mongo/db/transaction_participant_gen.h" #include "mongo/stdx/memory.h" #include "mongo/util/exit.h" #include "mongo/util/fail_point_service.h" @@ -1100,7 +1101,6 @@ Status multiSyncApply(OperationContext* opCtx, return Status::OK(); } - /** * ops - This only modifies the isForCappedCollection field on each op. It does not alter the ops * vector in any other way. @@ -1140,7 +1140,7 @@ void SyncTail::_fillWriterVectors(OperationContext* opCtx, // We need to track all types of ops, including type 'n' (these are generated from chunk // migrations). if (sessionUpdateTracker) { - if (auto newOplogWrites = sessionUpdateTracker->updateOrFlush(op)) { + if (auto newOplogWrites = sessionUpdateTracker->updateSession(op)) { derivedOps->emplace_back(std::move(*newOplogWrites)); _fillWriterVectors(opCtx, &derivedOps->back(), writerVectors, derivedOps, nullptr); } |