debug

zhangmeng

2020-01-13 a624336de555c4fcdaac56497f3f36ab920df1d5

debug

 run.go

@@ -23,6 +23,8 @@
)

func (f *face) channelAvailable() int {
    f.mapChanLock.Lock()
    defer f.mapChanLock.Unlock()

    for i := 0; i < f.maxChannel; i++ {
        found := false
@@ -55,20 +57,20 @@
}

func (f *face) channelNew(id string) *channel {
    f.mapChanLock.Lock()
    defer f.mapChanLock.Unlock()

    index := f.channelAvailable()
    if index < 0 {
        return nil
    }

    f.mapChanLock.Lock()
    c := &channel{
        index: index,
        msgs:  sdkhelper.NewLockList(6),
        msgs:  sdkhelper.NewLockList(3),
    }

    f.mapChan[id] = c
    f.mapChanLock.Unlock()

    return c
}

@@ -191,8 +193,6 @@

func (f *face) run(msgs []protomsg.SdkMessage, out chan<- sdkstruct.MsgSDK, typ string) {

    f.fnLogger("######run batch images")

    for _, msg := range msgs {
        if c, ok := f.channelExist(msg.Cid); ok {
            f.fnLogger("######push image: ", c.index)
@@ -220,8 +220,6 @@
            nc.msgs.Push(msg)
        }
    }
    f.fnLogger("######run over batch images")

}

func (f *face) detectTrackOneChn(c *channel, out chan<- sdkstruct.MsgSDK) {
@@ -236,7 +234,7 @@
        select {

        case <-time.After(trackChnTimeout * time.Second):
            f.fnLogger("Timeout to get image, curCid:", curCid)
            f.fnLogger("######Timeout to get image, curCid:", curCid)
            if curCid != "" {
                f.channelRelease(curCid)
            }
@@ -270,13 +268,9 @@
                // conv to bgr24 and resize
                imgW, imgH := int(i.Width), int(i.Height)

                f.fnLogger("######face sdk run: ", dtchn)
                count, data, _ := f.handle.Run(i.Data, imgW, imgH, 3, dtchn)
                f.fnLogger("######face over sdk run: ", dtchn)

                f.fnLogger("######face eject data: ", dtchn)
                sdkhelper.EjectResult(data, rMsg, out)
                f.fnLogger("######face over eject data: ", dtchn)

                var id, name string
                if rMsg.Tasklab != nil {