diff options
author | Gregory Noma <gregory.noma@gmail.com> | 2020-02-13 16:38:33 -0500 |
---|---|---|
committer | Gregory Noma <gregory.noma@gmail.com> | 2020-02-18 17:13:19 -0500 |
commit | a68508f9922ad163ff98f8fa13953b1efe9d57d0 (patch) | |
tree | 1ead40c94d7da611cbb6cd36a342cf76ffe2e452 /src/mongo/db/pipeline/process_interface/shardsvr_process_interface.cpp | |
parent | 11640b2138d40777a4b45005628b4facfba7e6b2 (diff) | |
download | mongo-46137.tar.gz |
SERVER-46137 Implement ReplicaSetNodeProcessInterface methods needed for $merge46137
Diffstat (limited to 'src/mongo/db/pipeline/process_interface/shardsvr_process_interface.cpp')
-rw-r--r-- | src/mongo/db/pipeline/process_interface/shardsvr_process_interface.cpp | 16 |
1 files changed, 2 insertions, 14 deletions
diff --git a/src/mongo/db/pipeline/process_interface/shardsvr_process_interface.cpp b/src/mongo/db/pipeline/process_interface/shardsvr_process_interface.cpp index 087a258a3fa..24ad6c9acca 100644 --- a/src/mongo/db/pipeline/process_interface/shardsvr_process_interface.cpp +++ b/src/mongo/db/pipeline/process_interface/shardsvr_process_interface.cpp @@ -61,18 +61,6 @@ using write_ops::Insert; using write_ops::Update; using write_ops::UpdateOpEntry; -namespace { - -// Attaches the write concern to the given batch request. If it looks like 'writeConcern' has -// been default initialized to {w: 0, wtimeout: 0} then we do not bother attaching it. -void attachWriteConcern(BatchedCommandRequest* request, const WriteConcernOptions& writeConcern) { - if (!writeConcern.wMode.empty() || writeConcern.wNumNodes > 0) { - request->setWriteConcern(writeConcern.toBSON()); - } -} - -} // namespace - bool ShardServerProcessInterface::isSharded(OperationContext* opCtx, const NamespaceString& nss) { Lock::DBLock dbLock(opCtx, nss.db(), MODE_IS); Lock::CollectionLock collLock(opCtx, nss, MODE_IS); @@ -127,7 +115,7 @@ Status ShardServerProcessInterface::insert(const boost::intrusive_ptr<Expression buildInsertOp(ns, std::move(objs), expCtx->bypassDocumentValidation)); // If applicable, attach a write concern to the batched command request. - attachWriteConcern(&insertCommand, wc); + CommonProcessInterface::attachWriteConcern(&insertCommand, wc); ClusterWriter::write(expCtx->opCtx, insertCommand, &stats, &response, targetEpoch); @@ -148,7 +136,7 @@ StatusWith<MongoProcessInterface::UpdateResult> ShardServerProcessInterface::upd BatchedCommandRequest updateCommand(buildUpdateOp(expCtx, ns, std::move(batch), upsert, multi)); // If applicable, attach a write concern to the batched command request. - attachWriteConcern(&updateCommand, wc); + CommonProcessInterface::attachWriteConcern(&updateCommand, wc); ClusterWriter::write(expCtx->opCtx, updateCommand, &stats, &response, targetEpoch); |