| | |
|---|
| | | } |
|---|
| | | 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 |
|---|
| | |
|---|
| | | 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 { |
|---|
