overflow_backup_2018_0455/overflow_gateway_websocket
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

ing

Browse Source
This commit is contained in:
crusader 2017-11-29 02:25:11 +09:00
parent a356983559
commit 43c744e9ad
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
internal/server/rpc/gateway_rpc_servlet_handlers.go
View File

@ -2,14 +2,15 @@ package rpc
import ( import (
"context" "context"
"fmt"
"git.loafle.net/commons_go/logging"
"git.loafle.net/commons_go/rpc" "git.loafle.net/commons_go/rpc"
crcwf "git.loafle.net/commons_go/rpc/connection/websocket/fasthttp" crcwf "git.loafle.net/commons_go/rpc/connection/websocket/fasthttp"
"git.loafle.net/commons_go/rpc/gateway" "git.loafle.net/commons_go/rpc/gateway"
"git.loafle.net/commons_go/rpc/protocol" "git.loafle.net/commons_go/rpc/protocol"
"git.loafle.net/commons_go/rpc/protocol/json" "git.loafle.net/commons_go/rpc/protocol/json"
oogw "git.loafle.net/overflow/overflow_gateway_websocket" oogw "git.loafle.net/overflow/overflow_gateway_websocket"
"git.loafle.net/overflow/overflow_gateway_websocket/external/grpc"
"google.golang.org/grpc/metadata" "google.golang.org/grpc/metadata"
) )
@ -45,10 +46,12 @@ func (sh *GatewayRPCServletHandlers) Invoke(servletCTX rpc.ServletContext, reque
return nil, err return nil, err
} }
r, err := grpc.Exec(grpcCTX, requestCodec.Method(), params) logging.Logger().Debug(fmt.Sprintf("method:%s, params:%v", requestCodec.Method(), params))
if err != nil { // r, err := grpc.Exec(grpcCTX, requestCodec.Method(), params)
return nil, err // if err != nil {
} // return nil, err
// }
r := struct{}{}
return r, nil return r, nil
} }