modified: daemon.go

daemon.go

@@ -149,20 +149,22 @@ func New(cfg *Config) (*Daemon, error) {
 
 	// if ctrl create supervise dir
 	if cfg.ctrl {
+		// create fifo
+		var ctrl = []string{"control", "ok"}
+		for _, v := range ctrl {
+			if err := MakeFifo(filepath.Join(supDir, v)); err != nil {
+				return nil, err
+			}
+		}
+
 		// lock
 		if lock, err := os.Create(filepath.Join(supDir, "lock")); err != nil {
 			return nil, err
 		} else if err = syscall.Flock(int(lock.Fd()), syscall.LOCK_EX+syscall.LOCK_NB); err != nil {
 			return nil, err
 		}
 
-		// fifo
-		var ctrl = []string{"control", "ok"}
-		for _, v := range ctrl {
-			if err := MakeFifo(filepath.Join(supDir, v)); err != nil {
-				return nil, err
-			}
-		}
+		// read fifo
 		if control.fifo_control, err = OpenFifo(filepath.Join(supDir, "control")); err != nil {
 			return nil, err
 		}