| | |
| | | |
| | | var shm bool = false |
| | | |
| | | var innerRecvTopic = []string{ |
| | | "facedetect-sdk-no-track", //to sdk-no-track 以图搜图 |
| | | } |
| | | |
| | | var innerSendTopic = []string{ |
| | | "facedetect-sdk-no-track", //to sdk-no-track 以图搜图 |
| | | "virtual-faceextract-sdk-pull", //to web 以图搜图 |
| | | } |
| | | |
| | | func initInnerTopic() { |
| | | // for _, sendTopic := range innerSendTopic { |
| | | // createSdkSendServerAndListen(sendTopic) |
| | | // } |
| | | |
| | | // for _, recvTopic := range innerRecvTopic { |
| | | // createSdkRecvServerAndListen(recvTopic) |
| | | // } |
| | | } |
| | | |
| | | func Init(useShm bool) { |
| | | |
| | | shm = useShm |
| | |
| | | logger.Info("============= init sdk info =====================") |
| | | for _, sdkid := range util.Sdklist { // 创建sdk server |
| | | createSdkTopicAndServer(sdkid) |
| | | logger.Info() |
| | | } |
| | | |
| | | // 手动输入的主题 |
| | | initInnerTopic() |
| | | |
| | | // es |
| | | SdkMap["es"] = make(chan protomsg.SdkMessage) |
| | | logger.Info("create es channel: ") |
| | | go DealEsTopic() |
| | | |
| | | go autoUpdateSdk(util.Sdkflag) |
| | | } |
| | |
| | | func createSdkSendServerAndListen(id string) { |
| | | if _, isExist := SdkMap[id]; !isExist { //不存在 |
| | | SdkMap[id] = make(chan protomsg.SdkMessage) |
| | | logger.Info("create", id) |
| | | } |
| | | |
| | | url := "ipc:///tmp/" + id + postPush + ".ipc" |
| | |
| | | url = id + postPush |
| | | } |
| | | |
| | | logger.Info("SDK URL: ", url) |
| | | |
| | | socket, err := util.NewSocketListen(int(m), url, shm) |
| | | if err != nil { |
| | | delete(SdkMap, id) |
| | | logger.Error(id, "create socket error!") |
| | | return |
| | | } |
| | | |
| | | SocketManage[id] = socket |
| | | logger.Info("SDK URL Send: ", url) |
| | | |
| | | go Send(id, socket, SdkMap[id]) |
| | | } |
| | |
| | | logger.Error(id, "create socket error!") |
| | | return |
| | | } |
| | | |
| | | SocketManage[id] = socket |
| | | logger.Info("SDK URL Recv: ", url) |
| | | |
| | | go Recv(socket) |
| | | } |
| | |
| | | } |
| | | |
| | | newSdkList := util.Sdklist |
| | | |
| | | // 手动添加的全部加上 |
| | | for _, sendTopic := range innerSendTopic { |
| | | newSdkList = append(newSdkList, sendTopic) |
| | | } |
| | | for _, recvTopic := range innerRecvTopic { |
| | | newSdkList = append(newSdkList, recvTopic) |
| | | } |
| | | |
| | | sdkListUpdate := util.Difference(oldSdkList, newSdkList) |
| | | logger.Info(sdkListUpdate) |
| | |
| | | func GetSdkSendTopic(sdkmsg protomsg.SdkMessage) (sendTopic string) { |
| | | if int(sdkmsg.Tasklab.Index) < len(sdkmsg.Tasklab.Sdkinfos) { |
| | | sendTopic = sdkmsg.Tasklab.Sdkinfos[sdkmsg.Tasklab.Index].Ipcid |
| | | if "Yolo" != sdkmsg.Tasklab.Sdkinfos[sdkmsg.Tasklab.Index].Sdktype && |
| | | "FaceDetect" != sdkmsg.Tasklab.Sdkinfos[sdkmsg.Tasklab.Index].Sdktype && |
| | | "FaceCompare" != sdkmsg.Tasklab.Sdkinfos[sdkmsg.Tasklab.Index].Sdktype { |
| | | //if sdkmsg.Tasklab.Sdkinfos[sdkmsg.Tasklab.Index].Sdktype == "" { |
| | | logger.Info("----------Sdktype:yitusoutu") |
| | | logger.Info("分发的主题:", sendTopic, "!Sdktype:", sdkmsg.Tasklab.Sdkinfos[sdkmsg.Tasklab.Index].Sdktype) |
| | | } |
| | | // if "Yolo" != sdkmsg.Tasklab.Sdkinfos[sdkmsg.Tasklab.Index].Sdktype && |
| | | // "FaceDetect" != sdkmsg.Tasklab.Sdkinfos[sdkmsg.Tasklab.Index].Sdktype && |
| | | // "FaceCompare" != sdkmsg.Tasklab.Sdkinfos[sdkmsg.Tasklab.Index].Sdktype { |
| | | // //if sdkmsg.Tasklab.Sdkinfos[sdkmsg.Tasklab.Index].Sdktype == "" { |
| | | // logger.Info("----------Sdktype:yitusoutu") |
| | | // logger.Info("分发的主题:", sendTopic, "!Sdktype:", sdkmsg.Tasklab.Sdkinfos[sdkmsg.Tasklab.Index].Sdktype) |
| | | // } |
| | | } else { |
| | | sendTopic = "es" |
| | | } |
| | |
| | | if tryCount > util.ShmMaxTryCount { |
| | | socket.Sock.Close() |
| | | socket, err = util.NewSocketListen(socket.Mode, socket.URL, socket.UseSHM) |
| | | logger.Info("SDK SEND SHM TRY :", util.ShmMaxTryCount, " RESTART IT") |
| | | // logger.Info("SDK SEND SHM TRY :", util.ShmMaxTryCount, " RESTART IT") |
| | | tryCount = 0 |
| | | continue |
| | | } |
| | |
| | | } |
| | | continue |
| | | } else { |
| | | |
| | | err = proto.Unmarshal(msg, &repsdkmsg) |
| | | if err != nil { |
| | | logger.Error("unmarshal error: ", err) |
| | |
| | | repsdkmsg.Tasklab.Index++ |
| | | //调用计算函数, 分发给下一个主题 |
| | | nexttopic := GetSdkSendTopic(repsdkmsg) |
| | | if "facedetect-sdk-no-track" == nexttopic || "virtual-faceextract-sdk-pull" == nexttopic { |
| | | logger.Info("nexttopic:", nexttopic) |
| | | } |
| | | SdkMap[nexttopic] <- repsdkmsg |
| | | logger.Info("recv from URL: ", socket.URL, " success: ", len(msg), " send to: ", repsdkmsg) |
| | | } |
| | | } |
| | | } |
| | |
| | | } |
| | | |
| | | if err := socket.Sock.Send(data); err != nil { |
| | | if "facedetect-sdk-no-track" == sdkid || "virtual-faceextract-sdk-pull" == sdkid { |
| | | logger.Error("failed send:sdkid=", sdkid) |
| | | } |
| | | |
| | | // tryCount++ |
| | | // socket = util.MaybeRestartSocket(socket, &tryCount) |
| | |
| | | if tryCount > util.ShmMaxTryCount { |
| | | socket.Sock.Close() |
| | | socket, err = util.NewSocketListen(socket.Mode, socket.URL, socket.UseSHM) |
| | | logger.Info("SDK SEND SHM TRY :", util.ShmMaxTryCount, " RESTART IT") |
| | | // logger.Info("SDK SEND SHM TRY :", util.ShmMaxTryCount, " RESTART IT") |
| | | tryCount = 0 |
| | | continue |
| | | } |
| | |
| | | |
| | | continue |
| | | } |
| | | if "facedetect-sdk-no-track" == sdkid || "virtual-faceextract-sdk-pull" == sdkid { |
| | | logger.Info(sdkid, " send success: ", len(data)) |
| | | } |
| | | |
| | | logger.Info("send to sdk id: ", sdkid, " success: ", len(data)) |
| | | |
| | | } else { |
| | | logger.Debug(sdkid, " 主题关闭, 关闭send()") |
| | | return |