run.go | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
run.go
@@ -6,6 +6,7 @@ "fmt" "io/ioutil" "os" "strings" "time" "unsafe" @@ -99,6 +100,12 @@ for { if err = sock.Listen(s.ipc); err != nil { suf := "ipc://" p := strings.Index(s.ipc, suf) if p >= 0 { file := s.ipc[p+len(string(suf)):] os.Remove(file) } s.fnLogger("can't listen on rep socket: ", err) time.Sleep(5 * time.Millisecond) } else {