From e6b7905ee621994fad2b829d27239486147eebac Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期四, 30 七月 2020 16:57:11 +0800
Subject: [PATCH] gaizhengshanchudiaoxianjinchengkeydebug
---
library.go | 8 +++++++-
softbus.go | 3 ++-
2 files changed, 9 insertions(+), 2 deletions(-)
diff --git a/library.go b/library.go
index c212100..242ac00 100644
--- a/library.go
+++ b/library.go
@@ -156,7 +156,11 @@
// sub浣跨敤涓�涓猻ocket
sockSub := OpenDgramSocket()
- sockSub.Bind(int(regReply.SubTopicKey))
+ // sockSub.Bind(int(regReply.SubTopicKey))
+ // 璁㈤槄涓婚
+ for _, v := range info.SubTopic {
+ sockSub.Sub(v, int(regReply.SubTopicKey))
+ }
// 鍚姩鎺ユ敹绾跨▼
go recvRoutine(ctx, sockSub, chSub)
sub := &subOReply{
@@ -198,6 +202,8 @@
// GetTopicInfo get topic info
func (h *Handle) GetTopicInfo(topic, typ string) int {
+ // 鎹涓嶆洿鏂�,鍏堢敤缂撳瓨,鍚﹀垯闇�瑕佹柊鍒涘缓涓�涓猻ocket,鏉ヤ粠manager璇锋眰key
+ // ***k
if v, ok := h.m[topic]; ok {
return v.sock.Port()
}
diff --git a/softbus.go b/softbus.go
index 520176f..5ae50df 100644
--- a/softbus.go
+++ b/softbus.go
@@ -76,7 +76,8 @@
return errors.New("C SoftBus Handle Is Nil")
}
if len(keys) == 0 {
- return errors.New("Live Queue Keys Is Nil")
+ C.wrap_fn_shm_rm_dead_queue(libsoftbus, nil, 0)
+ return nil
}
l := len(keys)
--
Gitblit v1.8.0