debug

zhangmeng

2020-01-14 75a839bc6468c3fede48d18e4be4ae262ccd0a44

debug

 run.go

@@ -174,8 +174,8 @@
    )
    ipcRcv := sdkhelper.GetIpcAddress(s.shm, s.id+postPull)
    ipcSnd := sdkhelper.GetIpcAddress(s.shm, s.id+postPush)
    chRcv := make(chan []byte, 3)
    chSnd := make(chan sdkstruct.MsgSDK, 3)
    chRcv := make(chan []byte, s.maxChannel)
    chSnd := make(chan sdkstruct.MsgSDK, s.maxChannel)

    rcver := sdkhelper.NewReciever(ipcRcv, chRcv, s.shm, s.fnLogger)
    snder := sdkhelper.NewSender(ipcSnd, chSnd, s.shm, s.fnLogger)