diff options
| author | Dan Larkin-York <dan.larkin-york@mongodb.com> | 2022-07-13 15:36:18 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2022-07-13 16:34:48 +0000 |
| commit | 9c85a2300462dbe4e831cae20207a32153cc25a1 (patch) | |
| tree | d7587614679d56853fd27aae719755ccb39dba94 | |
| parent | d74db703acfa112ded3c20d285c92ef0186568e6 (diff) | |
| download | mongo-9c85a2300462dbe4e831cae20207a32153cc25a1.tar.gz | |
SERVER-67547 Ensure time-series schema update status is as expected
| -rw-r--r-- | src/mongo/db/timeseries/bucket_catalog.cpp | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/mongo/db/timeseries/bucket_catalog.cpp b/src/mongo/db/timeseries/bucket_catalog.cpp index 5f2b06e9596..2fa543fe051 100644 --- a/src/mongo/db/timeseries/bucket_catalog.cpp +++ b/src/mongo/db/timeseries/bucket_catalog.cpp @@ -1280,8 +1280,9 @@ std::shared_ptr<BucketCatalog::WriteBatch> BucketCatalog::_insertIntoBucket( bucket->_memoryUsage += (info->key.ns.size() * 2) + doc.objsize() + sizeof(Bucket) + sizeof(std::unique_ptr<Bucket>) + (sizeof(Bucket*) * 2); - bucket->_schema.update( + auto updateStatus = bucket->_schema.update( doc, info->options.getMetaField(), info->key.metadata.getComparator()); + invariant(updateStatus == timeseries::Schema::UpdateStatus::Updated); } else { _memoryUsage.fetchAndSubtract(bucket->_memoryUsage); } |