SERVER-38191 Enforce restriction on namespace for failpoints in write_ops

1 files changed, 9 insertions, 2 deletions

diff --git a/src/mongo/db/curop_failpoint_helpers.cpp b/src/mongo/db/curop_failpoint_helpers.cpp
index 4df9311cc6d..fb78284f6f8 100644
--- a/src/mongo/db/curop_failpoint_helpers.cpp
+++ b/src/mongo/db/curop_failpoint_helpers.cpp
@@ -49,12 +49,19 @@ void CurOpFailpointHelpers::waitWhileFailPointEnabled(FailPoint* failPoint,
                                                       OperationContext* opCtx,
                                                       const std::string& curOpMsg,
                                                       const std::function<void(void)>& whileWaiting,
-                                                      bool checkForInterrupt) {
+                                                      bool checkForInterrupt,
+                                                      boost::optional<NamespaceString> nss) {
+
     invariant(failPoint);
     MONGO_FAIL_POINT_BLOCK((*failPoint), options) {
+        const BSONObj& data = options.getData();
+        StringData fpNss = data.getStringField("nss");
+        if (nss && !fpNss.empty() && fpNss != nss.get().toString()) {
+            return;
+        }
+
         auto origCurOpMsg = updateCurOpMsg(opCtx, curOpMsg);
 
-        const BSONObj& data = options.getData();
         const bool shouldCheckForInterrupt =
             checkForInterrupt || data["shouldCheckForInterrupt"].booleanSafe();
         while (MONGO_FAIL_POINT((*failPoint))) {