Request添加SrcProc返给上层

liuxiaolong

2021-01-22 29120c5fa5f9022816dc04841b039208a05e5324

Request添加SrcProc返给上层

 hbusc.go

@@ -437,7 +437,6 @@
    var ret []bhomebus.Mesg

    n := h.sockWorker.sock.SendandrecvTimeout(rNodes, data,&ret, milliSecs)
    h.printLog("Request n: ", n, " len(ret): ", len(ret))

    if n > 0 && len(ret) > 0 {
        var resp Reply
@@ -447,6 +446,8 @@
            h.printLog("unmarshal ret[0].Data err:", err)
            return nil, err
        }
    } else {
        h.printLog("Request n: ", n, " len(ret): ", len(ret))
    }
    return nil, fmt.Errorf("request err")
}

 micronode.go

@@ -189,25 +189,30 @@
    }

    var reqBody Request
    var ri *Reply
    err := json.Unmarshal(msgR.Body, &reqBody)
    if err != nil {
        ms.printLog("serve unmarshal msgR.Body err:", err)
        return
    }

    ms.printLog("reqBody:", reqBody, "to key: ", p)
    var ri *Reply
    if f,ok := ms.handlers[reqBody.Path];ok {
        ri = f(&reqBody)
        ms.printLog("call funcMap f,reply:", *ri)
        ri = &Reply {
            Msg: err.Error(),
        }
    } else {
        ms.printLog("ms.funcMap not eixst path")
        ri = &Reply{
            Success: false,
            Msg: "请求的接口不存在，请检查url",
            Data: "请求的接口不存在，请检查url",
        ms.printLog("reqBody:", reqBody, "to key: ", p)

        if f,ok := ms.handlers[reqBody.Path];ok {
            reqBody.SrcProc = msgR.SrcProc
            ri = f(&reqBody)
            ms.printLog("call funcMap f,reply:", *ri)
        } else {
            ms.printLog("ms.funcMap not eixst path")
            ri = &Reply{
                Success: false,
                Msg: "请求的接口不存在，请检查url",
                Data: "请求的接口不存在，请检查url",
            }
        }
    }

    retErr := ms.handle.Reply(p, ri)
    if retErr != nil {
        ms.printLog("retErr:", retErr)

 param.go

@@ -16,6 +16,8 @@
    Body                    []byte                  `json:"body"`
    File                    FileArg                 `json:"file"`
    MultiFiles                 []FileArg                `json:"multiFiles""`

    SrcProc                 ProcInfo                `json:"srcProc"`  //请求来源进程
}

type FileArg struct {