liuxiaolong
2019-08-31 df219a383a31b435f317ba6472cc87929cc052c6
sdk/sdk.go
@@ -217,6 +217,7 @@
         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)
@@ -264,6 +265,8 @@
            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)
@@ -275,6 +278,7 @@
                  }
                  tryCount++
               }
               continue
            }
            logger.Debug(sdkid, " send success: ", len(data))