debug

zhangmeng

2020-01-13 adb1044f1a5cb8f25178f5f5e6106d8adb3d4109

debug

 run.go

@@ -217,9 +217,7 @@
    wg := &sync.WaitGroup{}

    for _, msg := range msgs {
        f.fnLogger("######Maintain :", msg.Cid)
        f.chLife <- msg.Cid
        f.fnLogger("######Maintain Over :", msg.Cid)

        if c, ok := f.channelExist(msg.Cid); ok {
            wg.Add(1)
@@ -256,8 +254,6 @@

    rMsg := *msg

    f.fnLogger("######Recv From: ", rMsg.Cid, " Chan: ", tchan)

    if !sdkhelper.ValidRemoteMessage(rMsg, f.typ, f.fnLogger) {
        sdkhelper.EjectResult(nil, rMsg, out)
        f.fnLogger("Face!!!!!!SkdMessage Invalid: ", tchan)
@@ -276,13 +272,9 @@
    // conv to bgr24 and resize
    imgW, imgH := int(i.Width), int(i.Height)

    f.fnLogger("######Run cid:", rMsg.Cid, "chan: ", tchan)
    count, data, _ := f.handle.Run(i.Data, imgW, imgH, 3, tchan)
    f.fnLogger("######Over run cid:", rMsg.Cid, "chan: ", tchan)

    f.fnLogger("######Eject cid:", rMsg.Cid, "chan: ", tchan)
    sdkhelper.EjectResult(data, rMsg, out)
    f.fnLogger("######Over eject cid:", rMsg.Cid, "chan: ", tchan)

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