diff options
| author | Arun Banala <arun.banala@mongodb.com> | 2022-02-08 13:44:49 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2022-02-22 12:52:38 +0000 |
| commit | af85e60d19d1a975a7babf5300c6d336e474e40a (patch) | |
| tree | 77947d7687a43d749fee2393f78c683fd050135a /src/mongo/db/pipeline/document_source_check_resume_token_test.cpp | |
| parent | b6485b14e3749d1c6bc506fa5a5a3fd9b169af74 (diff) | |
| download | mongo-af85e60d19d1a975a7babf5300c6d336e474e40a.tar.gz | |
SERVER-62801 Add change stream event for create operation
Diffstat (limited to 'src/mongo/db/pipeline/document_source_check_resume_token_test.cpp')
| -rw-r--r-- | src/mongo/db/pipeline/document_source_check_resume_token_test.cpp | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/mongo/db/pipeline/document_source_check_resume_token_test.cpp b/src/mongo/db/pipeline/document_source_check_resume_token_test.cpp index 7c025a92766..afa2f70a422 100644 --- a/src/mongo/db/pipeline/document_source_check_resume_token_test.cpp +++ b/src/mongo/db/pipeline/document_source_check_resume_token_test.cpp @@ -535,7 +535,7 @@ TEST_F(CheckResumeTokenTest, ShardedResumeFailsOnMongosIfTokenHasSubsetOfDocumen TEST_F(CheckResumeTokenTest, ShardedResumeFailsOnMongosIfDocumentKeyIsNonObject) { // Verify that a resume token whose documentKey is not a valid object will neither succeed nor - // cause an invariant when we perform the relaxed documentKey._id check when running in a + // cause an invariant when we perform the relaxed eventIdentifier._id check when running in a // sharded context. Timestamp resumeTimestamp(100, 1); getExpCtx()->inMongos = true; @@ -551,8 +551,8 @@ TEST_F(CheckResumeTokenTest, ShardedResumeFailsOnMongosIfDocumentKeyIsNonObject) TEST_F(CheckResumeTokenTest, ShardedResumeFailsOnMongosIfDocumentKeyOmitsId) { // Verify that a resume token whose documentKey omits the _id field will neither succeed nor - // cause an invariant when we perform the relaxed documentKey._id, even when compared against an - // artificial stream token whose _id is also missing. + // cause an invariant when we perform the relaxed eventIdentifier._id, even when compared + // against an artificial stream token whose _id is also missing. Timestamp resumeTimestamp(100, 1); getExpCtx()->inMongos = true; @@ -607,7 +607,7 @@ TEST_F(CheckResumeTokenTest, ResumeToken::parse(firstDocAfterResume.getDocument()["_id"].getDocument()).getData(); ASSERT_EQ(tokenFromFirstDocAfterResume.clusterTime, resumeTimestamp); - ASSERT_DOCUMENT_EQ(tokenFromFirstDocAfterResume.documentKey.getDocument(), expectedDocKey); + ASSERT_DOCUMENT_EQ(tokenFromFirstDocAfterResume.eventIdentifier.getDocument(), expectedDocKey); } TEST_F(CheckResumeTokenTest, @@ -674,7 +674,7 @@ TEST_F(CheckResumeTokenTest, ShouldSwallowInvalidateFromEachShardForStartAfterIn ResumeToken::parse(firstDocAfterResume.getDocument()["_id"].getDocument()).getData(); ASSERT_EQ(tokenFromFirstDocAfterResume.clusterTime, firstEventAfter); - ASSERT_DOCUMENT_EQ(tokenFromFirstDocAfterResume.documentKey.getDocument(), expectedDocKey); + ASSERT_DOCUMENT_EQ(tokenFromFirstDocAfterResume.eventIdentifier.getDocument(), expectedDocKey); } TEST_F(CheckResumeTokenTest, ShouldNotSwallowUnrelatedInvalidateForStartAfterInvalidate) { @@ -750,7 +750,7 @@ TEST_F(CheckResumeTokenTest, ShouldSkipResumeTokensWithEarlierTxnOpIndex) { ResumeToken::parse(firstDocAfterResume.getDocument()["_id"].getDocument()).getData(); ASSERT_EQ(tokenFromFirstDocAfterResume.clusterTime, resumeTimestamp); - ASSERT_DOCUMENT_EQ(tokenFromFirstDocAfterResume.documentKey.getDocument(), expectedDocKey); + ASSERT_DOCUMENT_EQ(tokenFromFirstDocAfterResume.eventIdentifier.getDocument(), expectedDocKey); } /** |