add some log for recv/send
| | |
| | | "basic.com/valib/deliver.git" |
| | | ) |
| | | |
| | | const mode = deliver.Shm |
| | | const mode = deliver.PushPull |
| | | |
| | | // Reciever recv from ipc |
| | | type Reciever struct { |
| | |
| | | return |
| | | case msg := <-chMsg: |
| | | if len(msg.Tasklab.Sdkinfos) == 0 || int(msg.Tasklab.Index) >= len(msg.Tasklab.Sdkinfos) { |
| | | s.fnLogger("reid !!!!!! recv msg error") |
| | | continue |
| | | } |
| | | i := sdkhelper.UnpackImage(msg, "reid", s.fnLogger) |
| | |
| | | } |
| | | |
| | | sdkInfo := msg.Tasklab.Sdkinfos[int(msg.Tasklab.Index)] |
| | | s.fnLogger("reid !!!!!! recv from humantrack len: ", len(sdkInfo)) |
| | | |
| | | res := &protomsg.HumanTrackResult{} |
| | | if err := proto.Unmarshal(sdkInfo.Sdkdata, res); err != nil { |
| | | s.fnLogger(err, " sdkinfo msg Unmarshal 处理异常") |
| | |
| | | s.fnLogger(err, " msg Marshal 处理异常") |
| | | continue |
| | | } |
| | | s.fnLogger("reid !!!!!! send to humantrack len: ", len(data)) |
| | | |
| | | chSnd <- data |
| | | } |
| | | } |