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:31:29 +09:00
parent 43c744e9ad
commit 780b3e3521
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1,7 +1,6 @@
package rpc package rpc
import ( import (
"context"
"fmt" "fmt"
"git.loafle.net/commons_go/logging" "git.loafle.net/commons_go/logging"
@ -39,7 +38,7 @@ func (sh *GatewayRPCServletHandlers) WriteNotification(servletCTX rpc.ServletCon
func (sh *GatewayRPCServletHandlers) Invoke(servletCTX rpc.ServletContext, requestCodec protocol.RegistryCodec) (result interface{}, err error) { func (sh *GatewayRPCServletHandlers) Invoke(servletCTX rpc.ServletContext, requestCodec protocol.RegistryCodec) (result interface{}, err error) {
md := metadata.Pairs(oogw.GRPCUserIDKey, servletCTX.GetAttribute(oogw.SocketIDKey).(string)) md := metadata.Pairs(oogw.GRPCUserIDKey, servletCTX.GetAttribute(oogw.SocketIDKey).(string))
grpcCTX := metadata.NewOutgoingContext(context.Background(), md) // grpcCTX := metadata.NewOutgoingContext(context.Background(), md)
params, err := requestCodec.Params() params, err := requestCodec.Params()
if nil != err { if nil != err {