diff options
author | Wolfy-J <[email protected]> | 2018-06-23 20:21:12 +0300 |
---|---|---|
committer | Wolfy-J <[email protected]> | 2018-06-23 20:21:12 +0300 |
commit | 88b3416e0cb795873787014906b48d184f8fe78a (patch) | |
tree | 3fdebb92ef36277a43b9303703d8f22aa8edf9dd /service | |
parent | 008a42fc6138e74766cdf9011a8dfc60df71b4a0 (diff) |
better shutdown
Diffstat (limited to 'service')
-rw-r--r-- | service/http/service.go | 1 | ||||
-rw-r--r-- | service/rpc/service.go | 3 |
2 files changed, 2 insertions, 2 deletions
diff --git a/service/http/service.go b/service/http/service.go index 2df8656c..7fad3c49 100644 --- a/service/http/service.go +++ b/service/http/service.go @@ -105,7 +105,6 @@ func (s *Service) Stop() { atomic.AddInt32(&s.inStopping, 1) defer atomic.AddInt32(&s.inStopping, -1) - s.http.Shutdown(context.Background()) } diff --git a/service/rpc/service.go b/service/rpc/service.go index e1147754..c301e6bb 100644 --- a/service/rpc/service.go +++ b/service/rpc/service.go @@ -60,10 +60,11 @@ func (s *Service) Serve() error { for { select { case <-s.stop: - break + return default: conn, err := ln.Accept() if err != nil { + continue } |