Fix bugs.

winlinvip · Sep 1, 2024 · aa61564 · aa61564
1 parent 1217a4d
commit aa61564
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/proxy/srs.go b/proxy/srs.go
@@ -289,10 +289,9 @@ func (v *srsRedisLoadBalancer) Update(ctx context.Context, server *SRSServer) er
 	}
 
 	// Check each server expiration, if not exists in redis, remove from servers.
-	for i, serverKey := range serverKeys {
-		if _, err := v.rdb.Get(ctx, serverKey).Bytes(); err != nil {
+	for i := len(serverKeys) - 1; i >= 0; i-- {
+		if _, err := v.rdb.Get(ctx, serverKeys[i]).Bytes(); err != nil {
 			serverKeys = append(serverKeys[:i], serverKeys[i+1:]...)
-			continue
 		}
 	}
 

diff --git a/trunk/conf/origin1-for-proxy.conf b/trunk/conf/origin1-for-proxy.conf
@@ -17,7 +17,7 @@ heartbeat {
     enabled on;
     interval 9;
     url http://127.0.0.1:12025/api/v1/srs/register;
-    device_id origin2;
+    device_id origin1;
     ports on;
 }
 vhost __defaultVhost__ {