From c9603c6ea2f1fd07ab662f9ca5d2b5676357207f Mon Sep 17 00:00:00 2001
From: Mark Knapp <mknapp@hudson-trading.com>
Date: Fri, 13 Sep 2019 15:13:59 -0400
Subject: [PATCH] Add a flag to adjust mount timeout

Signed-off-by: Mark Knapp <mknapp@hudson-trading.com>
---
 collector/filesystem_linux.go | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/collector/filesystem_linux.go b/collector/filesystem_linux.go
index 5ba4fe15..98e51b87 100644
--- a/collector/filesystem_linux.go
+++ b/collector/filesystem_linux.go
@@ -26,14 +26,17 @@ import (
 
 	"github.com/prometheus/common/log"
 	"golang.org/x/sys/unix"
+	kingpin "gopkg.in/alecthomas/kingpin.v2"
 )
 
 const (
 	defIgnoredMountPoints = "^/(dev|proc|sys|var/lib/docker/.+)($|/)"
 	defIgnoredFSTypes     = "^(autofs|binfmt_misc|bpf|cgroup2?|configfs|debugfs|devpts|devtmpfs|fusectl|hugetlbfs|iso9660|mqueue|nsfs|overlay|proc|procfs|pstore|rpc_pipefs|securityfs|selinuxfs|squashfs|sysfs|tracefs)$"
-	mountTimeout          = 30 * time.Second
 )
 
+var mountTimeout = kingpin.Flag("collector.filesystem.mount-timeout",
+	"how long to wait for a mount to respond before marking it as stale").
+	Hidden().Default("5s").Duration()
 var stuckMounts = make(map[string]struct{})
 var stuckMountsMtx = &sync.Mutex{}
 
@@ -118,7 +121,7 @@ func stuckMountWatcher(mountPoint string, success chan struct{}) {
 	select {
 	case <-success:
 		// Success
-	case <-time.After(mountTimeout):
+	case <-time.After(*mountTimeout):
 		// Timed out, mark mount as stuck
 		stuckMountsMtx.Lock()
 		select {