overflow_cloud/container-go
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

ing

Browse Source
This commit is contained in:
crusader 2018-04-19 22:51:36 +09:00
parent 2efb6bf2ce
commit 21b4085bcc
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
servlet/rpc-servlet.go
View File

@ -50,6 +50,7 @@ func (s *RPCServlets) Handle(servletCtx server.ServletCtx,
err error err error
) )
sc := crpj.NewServerCodec() sc := crpj.NewServerCodec()
go s.handleRPCWrite(stopChan, writeChan)
for { for {
select { select {
@ -73,6 +74,15 @@ func (s *RPCServlets) Handle(servletCtx server.ServletCtx,
} }
writeChan <- replyBuff writeChan <- replyBuff
case <-stopChan:
return
}
}
}
func (s *RPCServlets) handleRPCWrite(stopChan <-chan struct{}, writeChan chan<- []byte) {
for {
select {
case buf, ok := <-s.RPCWriteChan: case buf, ok := <-s.RPCWriteChan:
if !ok { if !ok {
break break