From 9307cbbe2720d833739721bf6f178cfe041e17e6 Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期一, 02 九月 2019 13:54:42 +0800
Subject: [PATCH] Merge branch 'master' of ssh://192.168.1.14:29418/pubsub/task
---
sdk/sdk.go | 4 ++++
1 files changed, 4 insertions(+), 0 deletions(-)
diff --git a/sdk/sdk.go b/sdk/sdk.go
index 250753e..43e7c64 100644
--- a/sdk/sdk.go
+++ b/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))
--
Gitblit v1.8.0