rename

liuxiaolong

2021-04-02 7a1ec99729629666f84a6ac4be24355e8799a16c

rename

 hbusc.go

@@ -86,7 +86,7 @@
    }
}

//func recvandsendRoutine(ctx context.Context, s *bhomebus.Socket, wg *sync.WaitGroup,serveFn func(rdata []byte, rkey int, sdata *[]byte) bool, logFn func(...interface{})) {
//func recvandsendRoutine(h context.WrapperHandler, s *bhomebus.Socket, wg *sync.WaitGroup,serveFn func(rdata []byte, rkey int, sdata *[]byte) bool, logFn func(...interface{})) {
//    for {
//        select {
//        case <-ctx.Done():

 micronode.go

@@ -298,11 +298,11 @@

        if f,ok := ms.handlers[reqBody.Path];ok {
            reqBody.SrcProc = msgR.SrcProc
            ctx := Context{
            h := WrapperHandler{
                ms,
                ms,
            }
            ri = f(&ctx, &reqBody)
            ri = f(&h, &reqBody)
            ms.printLog("call funcMap f,reply.Success:", ri.Success)
        } else {
            ms.printLog("ms.funcMap not eixst path: ", reqBody.Path)

 requestTopic.go

@@ -1,11 +1,11 @@
package bhomeclient

type Context struct {
type WrapperHandler struct {
    Bk         Broker
    Tr         Transport
}

type MicroFunc func(ctx *Context, req *Request) *Reply
type MicroFunc func(h *WrapperHandler, req *Request) *Reply


type Transport interface {