| | |
| | | return |
| | | default: |
| | | if msg, err := socket.Sock.Recv(); err != nil { |
| | | // fmt.Println("SDK RECV ERROR: ", err) |
| | | if socket.UseSHM { |
| | | if tryCount > util.SHMMaxTryCount { |
| | | socket, err = util.NewSocketListen(socket.Mode, socket.URL, socket.UseSHM) |
| | |
| | | if err := socket.Sock.Send(data); err != nil { |
| | | logger.Error("failed send:sdkid=", sdkid) |
| | | |
| | | // fmt.Println("SDK SEND ERROR: ", err) |
| | | |
| | | if socket.UseSHM { |
| | | if tryCount > util.SHMMaxTryCount { |
| | | socket, err = util.NewSocketListen(socket.Mode, socket.URL, socket.UseSHM) |
| | |
| | | } |
| | | tryCount++ |
| | | } |
| | | |
| | | continue |
| | | } |
| | | logger.Debug(sdkid, " send success: ", len(data)) |