ing
This commit is contained in:
parent
82733cc45d
commit
9fd507f383
|
@ -68,10 +68,12 @@ func (sh *RPCGatewayServletHandlers) OnConnect(soc cwf.Socket) {
|
||||||
|
|
||||||
func (sh *RPCGatewayServletHandlers) Handle(soc cwf.Socket, stopChan <-chan struct{}, doneChan chan<- error) {
|
func (sh *RPCGatewayServletHandlers) Handle(soc cwf.Socket, stopChan <-chan struct{}, doneChan chan<- error) {
|
||||||
var err error
|
var err error
|
||||||
rpcServlet := retainRPCServlet(sh.gwRPCSH, sh.rpcRWCSH)
|
// rpcServlet := retainRPCServlet(sh.gwRPCSH, sh.rpcRWCSH)
|
||||||
|
|
||||||
|
rpcServlet := cRPC.NewServlet(sh.gwRPCSH, sh.rpcRWCSH)
|
||||||
|
|
||||||
defer func() {
|
defer func() {
|
||||||
releaseRPCServlet(rpcServlet)
|
// releaseRPCServlet(rpcServlet)
|
||||||
doneChan <- err
|
doneChan <- err
|
||||||
}()
|
}()
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue
Block a user