From a3569835596ed15a00ec594cadccb85150f66cea Mon Sep 17 00:00:00 2001 From: crusader Date: Wed, 29 Nov 2017 02:19:21 +0900 Subject: [PATCH] ing --- internal/server/rpc/rpc_gateway_servlet_handlers.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/internal/server/rpc/rpc_gateway_servlet_handlers.go b/internal/server/rpc/rpc_gateway_servlet_handlers.go index f0f0bbd..ccc813d 100644 --- a/internal/server/rpc/rpc_gateway_servlet_handlers.go +++ b/internal/server/rpc/rpc_gateway_servlet_handlers.go @@ -48,7 +48,7 @@ func (sh *RPCGatewayServletHandlers) Handshake(serverCTX cwf.ServerContext, ctx } func (sh *RPCGatewayServletHandlers) SocketContext(serverCTX cwf.ServerContext) cwf.SocketContext { - socketCTX := sh.SocketContext(serverCTX) + socketCTX := sh.ServletHandlers.SocketContext(serverCTX) return newServletContext(socketCTX) } @@ -73,9 +73,9 @@ func (sh *RPCGatewayServletHandlers) Handle(soc cwf.Socket, stopChan <-chan stru rpcDoneChan := make(chan error, 1) - // if err = rpcServlet.Start(soc.Context(), soc, rpcDoneChan); nil != err { - // return - // } + if err = rpcServlet.Start(soc.Context(), soc, rpcDoneChan); nil != err { + return + } select { case err = <-rpcDoneChan: