diff options
Diffstat (limited to 'src/mongo/db/pipeline/change_stream_pre_image_helpers.cpp')
| -rw-r--r-- | src/mongo/db/pipeline/change_stream_pre_image_helpers.cpp | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/src/mongo/db/pipeline/change_stream_pre_image_helpers.cpp b/src/mongo/db/pipeline/change_stream_pre_image_helpers.cpp index 68e2e6949f8..3bdbf3954c5 100644 --- a/src/mongo/db/pipeline/change_stream_pre_image_helpers.cpp +++ b/src/mongo/db/pipeline/change_stream_pre_image_helpers.cpp @@ -44,6 +44,10 @@ namespace mongo { void writeToChangeStreamPreImagesCollection(OperationContext* opCtx, const ChangeStreamPreImage& preImage) { const auto collectionNamespace = NamespaceString::kChangeStreamPreImagesNamespace; + tassert(5869404, + str::stream() << "Invalid pre-image document applyOpsIndex: " + << preImage.getId().getApplyOpsIndex(), + preImage.getId().getApplyOpsIndex() >= 0); // This lock acquisition can block on a stronger lock held by another operation modifying the // pre-images collection. There are no known cases where an operation holding an exclusive lock @@ -52,7 +56,9 @@ void writeToChangeStreamPreImagesCollection(OperationContext* opCtx, AutoGetCollection preimagesCollectionRaii(opCtx, collectionNamespace, LockMode::MODE_IX); UpdateResult res = Helpers::upsert(opCtx, collectionNamespace.toString(), preImage.toBSON()); tassert(5868601, - "Failed to insert a new document into pre-images collection", + str::stream() << "Failed to insert a new document into the pre-images collection: ts: " + << preImage.getId().getTs().toString() + << ", applyOpsIndex: " << preImage.getId().getApplyOpsIndex(), !res.existing && !res.upsertedId.isEmpty()); } } // namespace mongo |