diff options
| author | Cheahuychou Mao <mao.cheahuychou@gmail.com> | 2022-03-09 19:06:05 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2022-03-09 20:52:32 +0000 |
| commit | f0b8cf638b620660d1efff0207adff32b86dc72f (patch) | |
| tree | 5af491aec61792b03b9fe76d0b8d680d5c280f5b /src/mongo/db/op_observer_impl_test.cpp | |
| parent | 5f6cd9a3c69faef393b79e18b118b29f2cce0123 (diff) | |
| download | mongo-f0b8cf638b620660d1efff0207adff32b86dc72f.tar.gz | |
SERVER-63444 Make retryable findAndModify executed in internal transactions retryable across resharding
Diffstat (limited to 'src/mongo/db/op_observer_impl_test.cpp')
| -rw-r--r-- | src/mongo/db/op_observer_impl_test.cpp | 18 |
1 files changed, 18 insertions, 0 deletions
diff --git a/src/mongo/db/op_observer_impl_test.cpp b/src/mongo/db/op_observer_impl_test.cpp index 4c54e3e81df..3a3391dc26a 100644 --- a/src/mongo/db/op_observer_impl_test.cpp +++ b/src/mongo/db/op_observer_impl_test.cpp @@ -1934,6 +1934,12 @@ protected: ASSERT_FALSE(preImageOpTime.isNull()); OplogEntry preImage = *findByTimestamp(oplogs, preImageOpTime); ASSERT_BSONOBJ_EQ(update.updateArgs->preImageDoc.get(), preImage.getObject()); + if (updateOplogEntry.getSessionId()) { + ASSERT_EQ(*updateOplogEntry.getSessionId(), *preImage.getSessionId()); + } + if (updateOplogEntry.getTxnNumber()) { + ASSERT_EQ(*updateOplogEntry.getTxnNumber(), *preImage.getTxnNumber()); + } } else { ASSERT_FALSE(updateOplogEntry.getPreImageOpTime()); } @@ -1957,6 +1963,12 @@ protected: ASSERT_FALSE(postImageOpTime.isNull()); OplogEntry postImage = *findByTimestamp(oplogs, postImageOpTime); ASSERT_BSONOBJ_EQ(update.updateArgs->updatedDoc, postImage.getObject()); + if (updateOplogEntry.getSessionId()) { + ASSERT_EQ(*updateOplogEntry.getSessionId(), *postImage.getSessionId()); + } + if (updateOplogEntry.getTxnNumber()) { + ASSERT_EQ(*updateOplogEntry.getTxnNumber(), *postImage.getTxnNumber()); + } } else { ASSERT_FALSE(updateOplogEntry.getPostImageOpTime()); } @@ -2337,6 +2349,12 @@ protected: ASSERT_FALSE(preImageOpTime.isNull()); OplogEntry preImage = *findByTimestamp(oplogs, preImageOpTime); ASSERT_BSONOBJ_EQ(_deletedDoc, preImage.getObject()); + if (deleteOplogEntry.getSessionId()) { + ASSERT_EQ(*deleteOplogEntry.getSessionId(), *preImage.getSessionId()); + } + if (deleteOplogEntry.getTxnNumber()) { + ASSERT_EQ(*deleteOplogEntry.getTxnNumber(), *preImage.getTxnNumber()); + } } else { ASSERT_FALSE(deleteOplogEntry.getPreImageOpTime()); } |