create tmpfs root directory if not exists

2022-06-12 16:46:19 +08:00
parent 1cf8df7524
commit 4199caa5ef
1 changed files with 7 additions and 0 deletions
--- a/pkg/tmpfs/tmpfs.go
+++ b/pkg/tmpfs/tmpfs.go
@@ -42,6 +42,13 @@ func NewTmpfs(config commonconfig.TmpfsConfig) *Tmpfs {
 		Config:      config,
 		recordLocks: make(map[string]*sync.Mutex),
 	}
+	// check if the directory exists
+	if _, err := os.Stat(tmpfs.Config.Root); os.IsNotExist(err) {
+		err = os.MkdirAll(tmpfs.Config.Root, 0755)
+		if err != nil {
+			log.Fatalln("[tmpfs] Failed to create directory", tmpfs.Config.Root)
+		}
+	}
 	tmpfs.wg.Add(1)
 	go tmpfs.Cleaner()
 	return tmpfs