add log

zhangmeng

2019-12-17 3fc4fa8f8bf65030ee0969d73f958b11d90b7daf

add log

 camera/camera.go

@@ -182,7 +182,8 @@
                    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("=========CAMERA RECV SHM ERROR=========")
                        logger.Info("CAMERA RECV FROM:", socket.URL, " ERROR ", util.ShmMaxTryCount, " TIMES SO RESTART IT")
                        tryCount = 0
                        continue
                    }

 sdk/sdk.go

@@ -155,12 +155,12 @@
        newSdkList := util.Sdklist

        // 手动添加的全部加上
        for _, sendTopic := range innerSendTopic {
            newSdkList = append(newSdkList, sendTopic)
        }
        for _, recvTopic := range innerRecvTopic {
            newSdkList = append(newSdkList, recvTopic)
        }
        // for _, sendTopic := range innerSendTopic {
        //     newSdkList = append(newSdkList, sendTopic)
        // }
        // for _, recvTopic := range innerRecvTopic {
        //     newSdkList = append(newSdkList, recvTopic)
        // }

        sdkListUpdate := util.Difference(oldSdkList, newSdkList)
        logger.Info(sdkListUpdate)
@@ -190,15 +190,17 @@
    return sdkmsg
}

var logShouldUntil = 0

//sdk数据分发器
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")

        logShouldUntil++
        if logShouldUntil > 68 {
            logShouldUntil = 0
            logger.Info("=========分发的主题=========")
            logger.Info("分发的主题:", sendTopic, "!Sdktype：", sdkmsg.Tasklab.Sdkinfos[sdkmsg.Tasklab.Index].Sdktype)
        }
    } else {
@@ -230,7 +232,8 @@
                    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 RECV SHM ERROR=========")
                        logger.Info("SDK RECV FROM:", socket.URL, " ERROR ", util.ShmMaxTryCount, " TIMES SO RESTART IT")
                        tryCount = 0
                        continue
                    }
@@ -286,7 +289,8 @@
                        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 ERROR=========")
                            logger.Info("SDK SEND TO: ", socket.URL, " ERROR ", util.ShmMaxTryCount, " TIMES SO RESTART IT")
                            tryCount = 0
                            continue
                        }

 util/util.go

@@ -97,7 +97,6 @@

// create server
func NewSocketListen(mode int, url string, shm bool) (socket SocketContext, err error) {
    logger.Info("url is: ", url)
    ctx, cancel := context.WithCancel(context.Background())

    socket.Context = ctx