| | |
| | | return nil, fmt.Errorf("unmarshal reply.Body err:%s", err.Error()) |
| | | } |
| | | } else { |
| | | h.printLog("reply.Status:", reply.Status) |
| | | return nil, fmt.Errorf("REPLY STATUS:%d", reply.Status) |
| | | } |
| | | } else { |
| | | h.printLog("getNetNodeByTopic ret n:", n) |
| | | return nil, fmt.Errorf("GetNetNodeByTopic n:%d", n) |
| | | return nil, fmt.Errorf("GetNetNodeByTopic ret n:%d", n) |
| | | } |
| | | } |
| | | |
| | |
| | | func (ms *MicroNode) GetLocalNetNodeByTopic(topicName string) []bhomebus.NetNode { |
| | | netNodes, err := ms.handle.GetNetNodeByTopic(ms.serverId, ms.procInfo, topicName) |
| | | if err != nil { |
| | | ms.printLog("netNodes:", netNodes, "err:", err) |
| | | ms.printLog("topic:",topicName, " netNodes:", netNodes, "err:", err) |
| | | return nil |
| | | } |
| | | return netNodes |