diff options
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); |