Remove socket file if it already exists

anexia · Dec 29, 2022 · 127ff1c · 127ff1c
1 parent 6bbbeb5
commit 127ff1c
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/main/main.go b/main/main.go
@@ -189,6 +189,9 @@ func createInstances(configs []PoolConfig) (rmuxInstances []*rmux.RedisMultiplex
 		if config.Socket != "" {
 			syscall.Umask(0111)
 			log.Info("Initializing rmux server on socket %s", config.Socket)
+			if err = os.RemoveAll(config.Socket); err != nil {
+				return
+			}
 			rmuxInstance, err = rmux.NewRedisMultiplexer("unix", config.Socket, config.PoolSize)
 		} else {
 			log.Info("Initializing rmux server on host: %s and port: %d", config.Host, config.Port)