From f057fdf62bfcc34ec4e5f5639c6f2d712748acd7 Mon Sep 17 00:00:00 2001
From: liuxiaolong <liuxiaolong@aiotlink.com>
Date: 星期五, 25 十二月 2020 19:16:37 +0800
Subject: [PATCH] test sendandrecv
---
hbusc.go | 55 +++++++++++++++++++++++++++++++------------------------
1 files changed, 31 insertions(+), 24 deletions(-)
diff --git a/hbusc.go b/hbusc.go
index 4cd245e..6a0f245 100644
--- a/hbusc.go
+++ b/hbusc.go
@@ -146,32 +146,39 @@
Key: handle.conf.regKey,
})
}
- var rMsg []bhomebus.Mesg
- n := regSock.Sendandrecv(regAddr, msg, &rMsg) //n浠ｈ〃鎴愬姛鍙戦�佺殑鑺傜偣鐨勪釜鏁�
- handle.printLog("regSock.Sendandrecv n:", n, "len(rMsg):", len(rMsg))
- if n == 1 && len(rMsg) == 1 {
- var cr CommonReply
- if err = json.Unmarshal(rMsg[0].Data, &cr);err != nil {
- handle.printLog("unmarshal regReply err:", err)
- return nil, errors.New("unmarshal regReply err:"+err.Error())
- } else {
- if cr.Status == REPLY_SUCCESS {
- var rr RegisterReply
- if err = json.Unmarshal(cr.Body, &rr);err ==nil {
- regR = &rr
- break loop
- } else {
- handle.printLog("unmarshal RegisterReply err:", err)
- }
-
- } else {
- handle.printLog("cr.Status:", cr.Status, "Desc:", cr.Desc)
- }
-
+ for i:=0;i<100;i++{
+ time.Sleep(1*time.Second)
+ handle.printLog("i:", i)
+ if i == 99 {
+ break loop
}
- } else {
- time.Sleep(100 * time.Millisecond)
}
+ //var rMsg []bhomebus.Mesg
+ //n := regSock.Sendandrecv(regAddr, msg, &rMsg) //n浠ｈ〃鎴愬姛鍙戦�佺殑鑺傜偣鐨勪釜鏁�
+ //handle.printLog("regSock.Sendandrecv n:", n, "len(rMsg):", len(rMsg))
+ //if n == 1 && len(rMsg) == 1 {
+ // var cr CommonReply
+ // if err = json.Unmarshal(rMsg[0].Data, &cr);err != nil {
+ // handle.printLog("unmarshal regReply err:", err)
+ // return nil, errors.New("unmarshal regReply err:"+err.Error())
+ // } else {
+ // if cr.Status == REPLY_SUCCESS {
+ // var rr RegisterReply
+ // if err = json.Unmarshal(cr.Body, &rr);err ==nil {
+ // regR = &rr
+ // break loop
+ // } else {
+ // handle.printLog("unmarshal RegisterReply err:", err)
+ // }
+ //
+ // } else {
+ // handle.printLog("cr.Status:", cr.Status, "Desc:", cr.Desc)
+ // }
+ //
+ // }
+ //} else {
+ // time.Sleep(100 * time.Millisecond)
+ //}
}
}
--
Gitblit v1.8.0