ing
This commit is contained in:
parent
b5a6a7280c
commit
b630f1721c
|
@ -154,7 +154,7 @@ func handleConnection(s *server, soc *Socket) {
|
||||||
clientStopChan := make(chan struct{})
|
clientStopChan := make(chan struct{})
|
||||||
handleDoneChan := make(chan struct{})
|
handleDoneChan := make(chan struct{})
|
||||||
|
|
||||||
go handler.Handle(soc, clientStopChan, handleDoneChan)
|
go soc.sh.Handle(soc, clientStopChan, handleDoneChan)
|
||||||
|
|
||||||
select {
|
select {
|
||||||
case <-s.stopChan:
|
case <-s.stopChan:
|
||||||
|
@ -166,5 +166,4 @@ func handleConnection(s *server, soc *Socket) {
|
||||||
logging.Logger.Debug(fmt.Sprintf("Server: Client[%s] is disconnected.", soc.RemoteAddr()))
|
logging.Logger.Debug(fmt.Sprintf("Server: Client[%s] is disconnected.", soc.RemoteAddr()))
|
||||||
soc.Close()
|
soc.Close()
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue
Block a user