diff options
| author | Faustoleyva54 <fausto.leyva@mongodb.com> | 2023-03-22 16:18:22 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2023-03-22 17:42:59 +0000 |
| commit | 49d7ea47cd34fb3086407e018fa9b165a5fa749c (patch) | |
| tree | 774452facdf5258469ee6ba32619ef1fb73beb42 /src/mongo/db/timeseries/bucket_catalog/bucket_catalog.cpp | |
| parent | 82dc9512d081d97b8074b14a3fdbc212d9c1ed0f (diff) | |
| download | mongo-49d7ea47cd34fb3086407e018fa9b165a5fa749c.tar.gz | |
SERVER-75094 Prevent setting 'kPendingDirectWrite' flag on prepared buckets
Diffstat (limited to 'src/mongo/db/timeseries/bucket_catalog/bucket_catalog.cpp')
| -rw-r--r-- | src/mongo/db/timeseries/bucket_catalog/bucket_catalog.cpp | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/mongo/db/timeseries/bucket_catalog/bucket_catalog.cpp b/src/mongo/db/timeseries/bucket_catalog/bucket_catalog.cpp index 194e27f0600..6ee28976dea 100644 --- a/src/mongo/db/timeseries/bucket_catalog/bucket_catalog.cpp +++ b/src/mongo/db/timeseries/bucket_catalog/bucket_catalog.cpp @@ -329,6 +329,9 @@ void directWriteStart(BucketStateRegistry& registry, const NamespaceString& ns, BucketId{ns, oid}, [](boost::optional<BucketState> input, std::uint64_t) -> boost::optional<BucketState> { if (input.has_value()) { + if (input.value().isPrepared()) { + return input.value(); + } return input.value().addDirectWrite(); } // The underlying bucket isn't tracked by the catalog, but we need to insert a state |