zhangmeng
2023-12-05 2d5c411a22a653eb7cbde621db4e89b07755a852
remove sonic json dependency
1个文件已修改
5 ■■■■ 已修改文件
hbusc.go 5 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
hbusc.go
@@ -214,7 +214,6 @@
    h.printLog("h.wg.Wait done")
}
//HeartBeat send
func (h *BHBus) HeartBeat() error {
    procI := bhome_msg.ProcInfo{
@@ -228,8 +227,6 @@
        return errors.New("send heartBeat return false")
    }
}
//更新主题列表
func (h *BHBus) UpdateNodeTopics(arr []NodeInfo) {
@@ -304,6 +301,7 @@
    rep := bhome_msg.MsgRequestTopicReply{
        Data: data,
    }
    if bhsgo.SendReply(src, &rep) {
        return nil
    }
@@ -321,7 +319,6 @@
        return nil, errors.New("QueryProcs ret flase")
    }
}
//向主题通道中发布消息
func (h *BHBus) Pub(nodes []bhome_msg.BHAddress, msg *bhome_msg.MsgPublish) error {