fix: goroutine leak issue of cloudBlink

display.go

@@ -1,6 +1,7 @@
 package kvm
 
 import (
+	"context"
 	"errors"
 	"fmt"
 	"os"
@@ -110,10 +111,14 @@ func clearDisplayState() {
 	currentScreen = "ui_Boot_Screen"
 }
 
+const (
+	cloudBlinkInterval = 2 * time.Second
+	cloudBlinkDuration = 1 * time.Second
+)
+
 var (
-	cloudBlinkLock    sync.Mutex = sync.Mutex{}
+	cloudBlinkTicker *time.Ticker
-	cloudBlinkStopped bool
+	cloudBlinkCancel context.CancelFunc
-	cloudBlinkTicker  *time.Ticker
 )
 
 func updateDisplay() {
@@ -160,40 +165,48 @@ func updateDisplay() {
 }
 
 func startCloudBlink() {
-	if cloudBlinkTicker == nil {
+	// Stop any existing blink animation
-		cloudBlinkTicker = time.NewTicker(2 * time.Second)
+	stopCloudBlink()
-	} else {
-		// do nothing if the blink isn't stopped
-		if cloudBlinkStopped {
-			cloudBlinkLock.Lock()
-			defer cloudBlinkLock.Unlock()
 
-			cloudBlinkStopped = false
+	// Create new ticker and context
-			cloudBlinkTicker.Reset(2 * time.Second)
+	if cloudBlinkTicker == nil {
-		}
+		cloudBlinkTicker = time.NewTicker(cloudBlinkInterval)
+	} else {
+		cloudBlinkTicker.Reset(cloudBlinkInterval)
 	}
 
-	go func() {
+	ctx, cancel := context.WithCancel(context.Background())
-		for range cloudBlinkTicker.C {
+	cloudBlinkCancel = cancel
+
+	go doCloudBlink(ctx)
+}
+
+func doCloudBlink(ctx context.Context) {
+	for {
+		select {
+		case <-ctx.Done():
+			return
+		case <-cloudBlinkTicker.C:
 			if cloudConnectionState != CloudConnectionStateConnecting {
 				continue
 			}
-			_, _ = lvObjFadeOut("ui_Home_Header_Cloud_Status_Icon", 1000)
+			_, _ = lvObjFadeOut("ui_Home_Header_Cloud_Status_Icon", uint32(cloudBlinkDuration.Milliseconds()))
-			time.Sleep(1000 * time.Millisecond)
+			time.Sleep(cloudBlinkDuration)
-			_, _ = lvObjFadeIn("ui_Home_Header_Cloud_Status_Icon", 1000)
+			_, _ = lvObjFadeIn("ui_Home_Header_Cloud_Status_Icon", uint32(cloudBlinkDuration.Milliseconds()))
-			time.Sleep(1000 * time.Millisecond)
+			time.Sleep(cloudBlinkDuration)
 		}
-	}()
+	}
 }
 
 func stopCloudBlink() {
+	if cloudBlinkCancel != nil {
+		cloudBlinkCancel()
+		cloudBlinkCancel = nil
+	}
+
 	if cloudBlinkTicker != nil {
 		cloudBlinkTicker.Stop()
 	}
-
-	cloudBlinkLock.Lock()
-	defer cloudBlinkLock.Unlock()
-	cloudBlinkStopped = true
 }
 
 var (

resource/jetkvm_native.sha256

@@ -1 +1 @@
-6dabd0e657dd099280d9173069687786a4a8c9c25cf7f9e7ce2f940cab67c521
+01db2bbcd0bad46c3e21eb3cc5687d15df2153c3d8e2d4665b37acb55f0b5a57