debug reid shm as server

zhangmeng

2020-01-16 e15f06954707abc5042a29664dbd71abdaea1be2

debug reid shm as server

 rpc/recv.go

@@ -95,13 +95,13 @@
}

func (r *Reciever) runShm(ctx context.Context) {
    c, err := deliver.NewClientWithError(deliver.Shm, r.ipcURL)
    c, err := deliver.NewServerWithError(deliver.Shm, r.ipcURL)
    for {
        if err == nil {
            break
        }
        time.Sleep(1 * time.Second)
        c, err = deliver.NewClientWithError(deliver.Shm, r.ipcURL)
        c, err = deliver.NewServerWithError(deliver.Shm, r.ipcURL)
        r.fnLogger("CLIENT CREATE FAILED : ", err)
    }
    r.run(ctx, c)

 rpc/send.go

@@ -85,13 +85,13 @@
}

func (s *Sender) runShm(ctx context.Context) {
    c, err := deliver.NewClientWithError(deliver.Shm, s.ipcURL)
    c, err := deliver.NewServerWithError(deliver.Shm, s.ipcURL)
    for {
        if err == nil {
            break
        }
        time.Sleep(1 * time.Second)
        c, err = deliver.NewClientWithError(deliver.Shm, s.ipcURL)
        c, err = deliver.NewServerWithError(deliver.Shm, s.ipcURL)
        s.fnLogger("CLIENT CREATE FAILED : ", err)
    }
    s.run(ctx, c)

 run.go

@@ -120,8 +120,8 @@
        postPush = `_1`
    )

    ipcSnd := url + postPush
    ipcRcv := url + postPull
    ipcSnd := s.ipc + postPush
    ipcRcv := s.ipc + postPull

    sndURL := sdkhelper.GetIpcAddress(true, ipcSnd)
    rcvURL := sdkhelper.GetIpcAddress(true, ipcRcv)