tun2: loop forever at the foot of HandleConn

lib/tun2/server.go

@@ -361,52 +361,54 @@ func (s *Server) HandleConn(c net.Conn, isKCP bool) {
 	ticker := time.NewTicker(5 * time.Second)
 	defer ticker.Stop()
 
-	select {
+	for {
-	case <-ticker.C:
+		select {
-		err := connection.Ping()
+		case <-ticker.C:
-		if err != nil {
+			err := connection.Ping()
-			cancel()
+			if err != nil {
-		}
+				cancel()
-	case <-ctx.Done():
-		s.connlock.Lock()
-		delete(s.conns, c)
-		s.connlock.Unlock()
-
-		var conns []*Connection
-
-		val, ok := s.domains.Get(auth.Domain)
-		if ok {
-			conns, ok = val.([]*Connection)
-			if !ok {
-				ln.Error(err, connection.F(), ln.F{
-					"action": "looking_up_for_disconnect_removal",
-				})
-				return
 			}
-		}
+		case <-ctx.Done():
+			s.connlock.Lock()
+			delete(s.conns, c)
+			s.connlock.Unlock()
 
-		for i, cntn := range conns {
+			var conns []*Connection
-			if cntn.id == connection.id {
+
-				conns[i] = conns[len(conns)-1]
+			val, ok := s.domains.Get(auth.Domain)
-				conns = conns[:len(conns)-1]
+			if ok {
+				conns, ok = val.([]*Connection)
+				if !ok {
+					ln.Error(err, connection.F(), ln.F{
+						"action": "looking_up_for_disconnect_removal",
+					})
+					return
+				}
 			}
+
+			for i, cntn := range conns {
+				if cntn.id == connection.id {
+					conns[i] = conns[len(conns)-1]
+					conns = conns[:len(conns)-1]
+				}
+			}
+
+			if len(conns) != 0 {
+				s.domains.Set(auth.Domain, conns)
+			} else {
+				s.domains.Remove(auth.Domain)
+			}
+
+			ln.Log(connection.F(), ln.F{
+				"action": "client_disconnecting",
+			})
+
+			controlStream.Close()
+			session.Close()
+			c.Close()
+
+			return
 		}
-
-		if len(conns) != 0 {
-			s.domains.Set(auth.Domain, conns)
-		} else {
-			s.domains.Remove(auth.Domain)
-		}
-
-		ln.Log(connection.F(), ln.F{
-			"action": "client_disconnecting",
-		})
-
-		controlStream.Close()
-		session.Close()
-		c.Close()
-
-		return
 	}
 }