MGM: make the Fuse bypass application name configurable (default 'fuse::restic') via EOS_MGM_FUSEX_NOSTALL_APP

Author: apeters1971

mgm/XrdMgmOfs.hh

@@ -220,6 +220,11 @@ namespace eos::mgm::placement
 class FSScheduler;
 }
 
+namespace eos::mgm::FuseServer
+{
+class Server;
+}
+
 enum class NamespaceState {
   kDown = 0,
   kBooting = 1,
@@ -252,6 +257,7 @@ public:
   friend class eos::mgm::SpaceCmd;
   friend class eos::mgm::FsckEntry;
   friend class eos::mgm::NsCmd;
+  friend class eos::mgm::FuseServer::Server;
   //----------------------------------------------------------------------------
   //! Constructor
   //----------------------------------------------------------------------------
@@ -2157,6 +2163,8 @@ private:
   static thread_local eos::common::LogId tlLogId;
   //! Space/quota which is requested when placing a file via FUSE(x)
   uint64_t mFusePlacementBooking;
+  //! NoStall FUSE applicationg name
+  std::string mFuseNoStallApp;
 
   //----------------------------------------------------------------------------
   //! Convert error code to string representation

mgm/XrdMgmOfs/ShouldStall.cc

@@ -63,7 +63,7 @@ XrdMgmOfs::ShouldStall(const char* function,
   size_t uid_threads = 1;
 
   if (stall) {
-    if ((vid.uid > 3) && (functionname != "stat")  && (vid.app != "fuse::restic")) {
+    if ((vid.uid > 3) && (functionname != "stat")  && (vid.app != gOFS->mFuseNoStallApp)) {
       if ((stalltime = gOFS->mTracker.ShouldStall(vid.uid, saturated, uid_threads))) {
         smsg = SSTR("operate - uid=" << vid.uid << " exceeding the "
                     "thread pool limit");
@@ -129,7 +129,7 @@ XrdMgmOfs::ShouldStall(const char* function,
         std::map<std::string, std::string>::const_iterator it;
 
         if ((functionname != "stat") &&  // never stall stats
-            (vid.app != "fuse::restic")) {
+            (vid.app != gOFS->mFuseNoStallApp)) {
           for (it = Access::gStallRules.begin();
                it != Access::gStallRules.end();
                it++) {

mgm/XrdMgmOfsConfigure.cc

@@ -1645,6 +1645,13 @@ XrdMgmOfs::Configure(XrdSysError& Eroute)
     MgmConfigAutoLoad = getenv("EOS_AUTOLOAD_CONFIG");
   }
 
+  // NoStall Fuse Application Name
+  if (getenv("EOS_MGM_FUSEX_NOSTALL_APP")) {
+    mFuseNoStallApp = getenv("EOS_MGM_FUSEX_NOSTALL_APP");
+  } else {
+    mFuseNoStallApp = "fuse::restic";
+  }
+
   XrdOucString instancepath = "/eos/";
   MgmProcPath = "/eos/";
   XrdOucString subpath = MgmOfsInstanceName;

misc/etc/sysconfig/eos_env.example

@@ -364,8 +364,10 @@ EOS_TTY_BROACAST_EGREP="\"CRIT|ALERT|EMERG|PROGRESS\""
 # ------------------------------------------------------------------
 
 # uncomment to change the minimum needed size available to create a new file
-# EOS_MGM_FUSE_BOOKING_SIZE = 5368709120
+# EOS_MGM_FUSE_BOOKING_SIZE=5368709120
 
+# define the name of the FUSE application, which can by-pass throttling & stalling
+# EOS_MGM_FUSEX_NOSTALL_APP="fuse::restic"
 
 # ------------------------------------------------------------------
 # MGM 'xrdfs query space' configuration