summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/sync_tail.cpp
diff options
context:
space:
mode:
authorJason Chan <jason.chan@10gen.com>2019-04-08 12:55:52 -0400
committerJason Chan <jason.chan@10gen.com>2019-04-08 13:49:56 -0400
commitac77a440f9df976234c2fe92c6726348e592ca8d (patch)
treee1bb1ad9c0b786750740d1edc7f5b152af2ccdcb /src/mongo/db/repl/sync_tail.cpp
parentbfa61a6b053de26ca47b7baad7a415f5bcdfae2c (diff)
downloadmongo-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.cpp4
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);
}