Request和RequestTopic暴露超时时间

liuxiaolong

2021-01-14 a09747afcca12a674c0138ae777b6166330fbdec

Request和RequestTopic暴露超时时间

 micronode.go

@@ -110,7 +110,7 @@
    }
}

func (ms *MicroNode) Request(serverId string, request Request) (*Reply,error) {
func (ms *MicroNode) Request(serverId string, request Request, milliSecs int) (*Reply,error) {
    t := time.Now()

    ms.printLog("1:", time.Since(t))
@@ -122,7 +122,7 @@
    }
    ms.printLog("2:", time.Since(t))
    t = time.Now()
    mi,err := ms.handle.Request(serverId, msgR, 5000)
    mi,err := ms.handle.Request(serverId, msgR, milliSecs)
    if mi == nil || err != nil {
        return nil, err
    }
@@ -142,14 +142,14 @@
    return ri, nil
}

func (ms *MicroNode) RequestTopic(serverId string, request Request) (*Reply,error) {
func (ms *MicroNode) RequestTopic(serverId string, request Request, milliSecs int) (*Reply,error) {
    rb, _ := json.Marshal(request)
    msgR := &MsgInfo{
        Topic: request.Path,
        Body: rb,
    }

    mi, err := ms.handle.Request(serverId, msgR, 5000)
    mi, err := ms.handle.Request(serverId, msgR, milliSecs)
    if err != nil {
        return nil, err
    }

 requestTopic.go

@@ -4,5 +4,5 @@


type Transport interface {
    RequestTopic(string, Request) (*Reply,error)
    RequestTopic(string, Request, int) (*Reply,error)
}