ing
This commit is contained in:
parent
f9b9c0ac97
commit
11ee798e72
|
@ -67,7 +67,7 @@ func (sh *ServerHandlers) Validate() {
|
||||||
sh.ServerHandlers.Validate()
|
sh.ServerHandlers.Validate()
|
||||||
|
|
||||||
if "" == sh.pidPath {
|
if "" == sh.pidPath {
|
||||||
logging.Logger().Panic(fmt.Sprintf("Server: The path of pid file must be specified"))
|
logging.Logger().Panicf("Server: The path of pid file must be specified")
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
@ -66,6 +66,7 @@ func (sh *SocketHandlers) Handle(soc server.Socket, stopChan <-chan struct{}, do
|
||||||
|
|
||||||
select {
|
select {
|
||||||
case err = <-rpcDoneChan:
|
case err = <-rpcDoneChan:
|
||||||
|
|
||||||
case <-stopChan:
|
case <-stopChan:
|
||||||
rpcServlet.Stop()
|
rpcServlet.Stop()
|
||||||
<-rpcDoneChan
|
<-rpcDoneChan
|
||||||
|
|
Loading…
Reference in New Issue
Block a user