Fix node stop listening if too many open files and add retry count be…

…fore panic

Signed-off-by: Yilun <[email protected]>

net/chord/net.go

@@ -713,18 +713,27 @@ func (t *TCPTransport) reapOnce() {
 
 // Listens for inbound connections
 func (t *TCPTransport) listen() {
+	errCount := 0
 	for {
 		conn, err := t.sock.AcceptTCP()
 		if err != nil {
+			if errCount < 10 {
+				errCount++
+			} else {
+				panic("Cannot accept new connections: " + err.Error())
+			}
+
 			if atomic.LoadInt32(&t.shutdown) == 0 {
 				log.Printf("[ERR] Error accepting TCP connection! %s\n", err)
-				time.Sleep(time.Millisecond * 300) // Add delay before try again sock Accept
+				time.Sleep(1 * time.Second)
 				continue
 			} else {
 				return
 			}
 		}
 
+		errCount = 0
+
 		// Setup the conn
 		t.setupConn(conn)
 

net/node/link.go

@@ -149,12 +149,23 @@ func (n *node) initConnection() {
 			return
 		}
 	}
+
+	errCount := 0
 	for {
 		conn, err := listener.Accept()
 		if err != nil {
+			if errCount < 10 {
+				errCount++
+			} else {
+				panic("Cannot accept new connections: " + err.Error())
+			}
+
 			log.Error("Error accepting ", err.Error())
-			return
+			time.Sleep(1 * time.Second)
+			continue
 		}
+
+		errCount = 0
 		log.Info("Remote node connect with ", conn.RemoteAddr(), conn.LocalAddr())
 
 		n.link.connCnt++