summaryrefslogtreecommitdiff
path: root/src/mongo/db/dbhelpers.cpp
diff options
context:
space:
mode:
authorDan Larkin-York <dan.larkin-york@mongodb.com>2021-04-01 23:06:23 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2021-04-02 00:01:02 +0000
commitb55f6c86a1a47f28de7815ef942c3c422590dea9 (patch)
tree3ad4664be27f03f0e601d1fb6fd32d4276ca25f6 /src/mongo/db/dbhelpers.cpp
parentc8e74f9e82a9aab3f549ff77aa539fa6b3ab6b45 (diff)
downloadmongo-b55f6c86a1a47f28de7815ef942c3c422590dea9.tar.gz
SERVER-55060 Direct modification must remove buckets from the time-series bucket catalog
Diffstat (limited to 'src/mongo/db/dbhelpers.cpp')
-rw-r--r--src/mongo/db/dbhelpers.cpp8
1 files changed, 6 insertions, 2 deletions
diff --git a/src/mongo/db/dbhelpers.cpp b/src/mongo/db/dbhelpers.cpp
index 3fc790e9bec..0d4f4bebeec 100644
--- a/src/mongo/db/dbhelpers.cpp
+++ b/src/mongo/db/dbhelpers.cpp
@@ -249,7 +249,9 @@ UpdateResult Helpers::upsert(OperationContext* opCtx,
request.setQuery(filter);
request.setUpdateModification(write_ops::UpdateModification::parseFromClassicUpdate(updateMod));
request.setUpsert();
- request.setFromMigration(fromMigrate);
+ if (fromMigrate) {
+ request.setSource(OperationSource::kFromMigrate);
+ }
request.setYieldPolicy(PlanYieldPolicy::YieldPolicy::NO_YIELD);
return ::mongo::update(opCtx, context.db(), request);
@@ -268,7 +270,9 @@ void Helpers::update(OperationContext* opCtx,
request.setQuery(filter);
request.setUpdateModification(write_ops::UpdateModification::parseFromClassicUpdate(updateMod));
- request.setFromMigration(fromMigrate);
+ if (fromMigrate) {
+ request.setSource(OperationSource::kFromMigrate);
+ }
request.setYieldPolicy(PlanYieldPolicy::YieldPolicy::NO_YIELD);
::mongo::update(opCtx, context.db(), request);