summaryrefslogtreecommitdiff
path: root/src/mongo/db/pipeline/resume_token.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/pipeline/resume_token.cpp')
-rw-r--r--src/mongo/db/pipeline/resume_token.cpp7
1 files changed, 3 insertions, 4 deletions
diff --git a/src/mongo/db/pipeline/resume_token.cpp b/src/mongo/db/pipeline/resume_token.cpp
index d1a54e4cb52..cc6d3631fd3 100644
--- a/src/mongo/db/pipeline/resume_token.cpp
+++ b/src/mongo/db/pipeline/resume_token.cpp
@@ -50,9 +50,9 @@ namespace {
// Helper function for makeHighWaterMarkToken and isHighWaterMarkToken.
ResumeTokenData makeHighWaterMarkResumeTokenData(Timestamp clusterTime, int version) {
ResumeTokenData tokenData;
+ tokenData.version = version;
tokenData.clusterTime = clusterTime;
tokenData.tokenType = ResumeTokenData::kHighWaterMarkToken;
- tokenData.version = version;
return tokenData;
}
} // namespace
@@ -297,9 +297,8 @@ ResumeToken ResumeToken::parse(const Document& resumeDoc) {
return ResumeToken(resumeDoc);
}
-ResumeToken ResumeToken::makeHighWaterMarkToken(Timestamp clusterTime) {
- return ResumeToken(
- makeHighWaterMarkResumeTokenData(clusterTime, ResumeTokenData::kDefaultTokenVersion));
+ResumeToken ResumeToken::makeHighWaterMarkToken(Timestamp clusterTime, int version) {
+ return ResumeToken(makeHighWaterMarkResumeTokenData(clusterTime, version));
}
bool ResumeToken::isHighWaterMarkToken(const ResumeTokenData& tokenData) {