hbusc.go | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
hbusc.go
@@ -537,11 +537,11 @@ if h.sockHB == nil && h.sockRep == nil && h.sockPub == nil && h.sockSub == nil && h.sockWorker == nil { return nil,nil, -1 } if len(h.chSub) >1 { if len(h.chSub) >0 { m := <-h.chSub subMsg = m.info } if len(h.chReply) > 1 { if len(h.chReply) >0 { m := <-h.chReply replyMsg = m.info replyKey = m.port