debug reid shm as server 2

zhangmeng

2020-01-16 e796f659289cba74d93bfacb23722c11c04926f0

debug reid shm as server 2

 rpc/recv.go

@@ -56,13 +56,13 @@
                    i.Close()
                    r.fnLogger("ANALYSIS RECV ERROR: ", err)

                    c, err := deliver.NewClientWithError(deliver.Shm, r.ipcURL)
                    c, err := deliver.NewServerWithError(deliver.Shm, r.ipcURL)
                    for {
                        if err == nil {
                            break
                        }
                        time.Sleep(time.Second)
                        c, err = deliver.NewClientWithError(deliver.Shm, r.ipcURL)
                        c, err = deliver.NewServerWithError(deliver.Shm, r.ipcURL)
                        r.fnLogger("ANALYSIS CREATE FAILED : ", err)
                    }
                    i = c

 rpc/send.go

@@ -57,13 +57,13 @@
                    i.Close()
                    s.fnLogger("ANALYSIS SENDER ERROR: ", err)

                    c, err := deliver.NewClientWithError(deliver.Shm, s.ipcURL)
                    c, err := deliver.NewServerWithError(deliver.Shm, s.ipcURL)
                    for {
                        if err == nil {
                            break
                        }
                        time.Sleep(time.Second)
                        c, err = deliver.NewClientWithError(deliver.Shm, s.ipcURL)
                        c, err = deliver.NewServerWithError(deliver.Shm, s.ipcURL)
                        s.fnLogger("CLIENT CREATE FAILED : ", err)
                    }
                    i = c