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