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)
