修复Sendandrecv返回值n的问题

liuxiaolong

2021-01-07 979421f803da6988f801cb093582efba3b3c03bc

修复Sendandrecv返回值n的问题

 hbusc.go

@@ -419,7 +419,7 @@
    }
    var ret []bhomebus.Mesg

    if n := h.sockWorker.sock.SendandrecvTimeout(rNodes, data,&ret, milliSecs);n == 0 {
    if n := h.sockWorker.sock.SendandrecvTimeout(rNodes, data,&ret, milliSecs);n > 0 {
        if len(ret) > 0 {
            if err = json.Unmarshal(ret[0].Data, resp); err == nil {
                return resp, nil
@@ -470,7 +470,7 @@
    h.mtxWorker.Lock()
    defer h.mtxWorker.Unlock()
    var ret []bhomebus.Mesg
    if n := h.sockWorker.sock.SendandrecvTimeout(rNodes, data,&ret, h.conf.sendTimeOut);n == 0 {
    if n := h.sockWorker.sock.SendandrecvTimeout(rNodes, data,&ret, h.conf.sendTimeOut);n > 0 {
        if len(ret) > 0 {
            var cr *CommonReply
            if err = json.Unmarshal(ret[0].Data, cr); err == nil {