| | |
| | | |
| | | c := deliver.NewClient(deliver.ReqRep, s.ipc) |
| | | |
| | | sendTry := 0 |
| | | recvTry := 0 |
| | | maxTry := 30 |
| | | |
| | | var msg []byte |
| | | var err error |
| | | |
| | |
| | | for { |
| | | msg, err = c.Recv() |
| | | if err == nil { |
| | | recvTry = 0 |
| | | break |
| | | } |
| | | recvTry++ |
| | | if recvTry > maxTry { |
| | | break |
| | | } |
| | | s.fnLogger("REID~~~~~~Recv From HumanTrack error: ", err) |
| | | time.Sleep(5 * time.Millisecond) |
| | | continue |
| | | } |
| | | |
| | | if recvTry > maxTry { |
| | | recvTry = 0 |
| | | continue |
| | | } |
| | | |
| | |
| | | for { |
| | | err = c.Send(buf) |
| | | if err == nil { |
| | | sendTry = 0 |
| | | break |
| | | } |
| | | if sendTry > maxTry { |
| | | sendTry = 0 |
| | | s.fnLogger("REID~~~~~~Send HumanTrack try: ", maxTry) |
| | | break |
| | | } |
| | | s.fnLogger("REID~~~~~~Send HumanTrack error: ", err) |