handle accept error, fix #607

CodisLabs · Dec 31, 2015 · 53bad85 · 53bad85
1 parent 3f3ce18
commit 53bad85
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/pkg/proxy/proxy.go b/pkg/proxy/proxy.go
@@ -140,6 +140,12 @@ func (s *Server) handleConns() {
 	for {
 		c, err := s.listener.Accept()
 		if err != nil {
+			if ne, ok := err.(net.Error); ok && ne.Temporary() {
+				log.WarnErrorf(err, "[%p] proxy accept new connection failed, get temporary error", s)
+				time.Sleep(time.Millisecond*10)
+				continue
+			}
+			log.WarnErrorf(err, "[%p] proxy accept new connection failed, get non-temporary error, must shutdown", s)
 			return
 		} else {
 			ch <- c