From 979421f803da6988f801cb093582efba3b3c03bc Mon Sep 17 00:00:00 2001
From: liuxiaolong <liuxiaolong@aiotlink.com>
Date: 星期四, 07 一月 2021 11:09:47 +0800
Subject: [PATCH] 修复Sendandrecv返回值n的问题
---
hbusc.go | 4 ++--
1 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/hbusc.go b/hbusc.go
index 8482f58..37429f8 100644
--- a/hbusc.go
+++ b/hbusc.go
@@ -419,7 +419,7 @@
}
var ret []bhomebus.Mesg
- if n := h.sockWorker.sock.SendandrecvTimeout(rNodes, data,&ret, milliSecs);n == 0 {
+ if n := h.sockWorker.sock.SendandrecvTimeout(rNodes, data,&ret, milliSecs);n > 0 {
if len(ret) > 0 {
if err = json.Unmarshal(ret[0].Data, resp); err == nil {
return resp, nil
@@ -470,7 +470,7 @@
h.mtxWorker.Lock()
defer h.mtxWorker.Unlock()
var ret []bhomebus.Mesg
- if n := h.sockWorker.sock.SendandrecvTimeout(rNodes, data,&ret, h.conf.sendTimeOut);n == 0 {
+ if n := h.sockWorker.sock.SendandrecvTimeout(rNodes, data,&ret, h.conf.sendTimeOut);n > 0 {
if len(ret) > 0 {
var cr *CommonReply
if err = json.Unmarshal(ret[0].Data, cr); err == nil {
--
Gitblit v1.8.0