From 747dacfed473dd21bc0274c359ecd9796d2a547b Mon Sep 17 00:00:00 2001 From: lianjun-zhang Date: Tue, 27 Aug 2024 19:25:16 +0800 Subject: [PATCH 1/4] =?UTF-8?q?=E4=BF=AE=E5=A4=8Dvcjob=20pod=E9=87=8D?= =?UTF-8?q?=E8=B0=83=E5=BA=A6ranktable?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pkg/ring-controller/ranktable/v2/ranktable.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pkg/ring-controller/ranktable/v2/ranktable.go b/pkg/ring-controller/ranktable/v2/ranktable.go index b527603..0015c67 100644 --- a/pkg/ring-controller/ranktable/v2/ranktable.go +++ b/pkg/ring-controller/ranktable/v2/ranktable.go @@ -19,6 +19,7 @@ import ( "fmt" "sort" "strconv" + "sync" apiCoreV1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/types" @@ -116,5 +117,5 @@ func (r *RankTable) GetPodNum() int { // DeletePod delete pod in server when pod is deleted func (r *RankTable) DeletePod(podID types.UID) { - r.Servers.Delete(podID) + r.Servers = &sync.Map{} } -- Gitee From 3ab8a868b8cf424f05c1f40316e4253069f3294e Mon Sep 17 00:00:00 2001 From: Lianjun Zhang Atlas Date: Tue, 27 Aug 2024 12:33:18 +0000 Subject: [PATCH 2/4] test Signed-off-by: Lianjun Zhang Atlas --- pkg/ring-controller/ranktable/v2/ranktable.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pkg/ring-controller/ranktable/v2/ranktable.go b/pkg/ring-controller/ranktable/v2/ranktable.go index 0015c67..c4850c5 100644 --- a/pkg/ring-controller/ranktable/v2/ranktable.go +++ b/pkg/ring-controller/ranktable/v2/ranktable.go @@ -117,5 +117,6 @@ func (r *RankTable) GetPodNum() int { // DeletePod delete pod in server when pod is deleted func (r *RankTable) DeletePod(podID types.UID) { - r.Servers = &sync.Map{} + r.Servers.Delete(podID) + // r.Servers = &sync.Map{} } -- Gitee From 07aad949a86dad5b5d7e97aea96b7d024f407423 Mon Sep 17 00:00:00 2001 From: Lianjun Zhang Atlas Date: Tue, 27 Aug 2024 12:34:48 +0000 Subject: [PATCH 3/4] test Signed-off-by: Lianjun Zhang Atlas --- pkg/ring-controller/ranktable/v2/ranktable.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/pkg/ring-controller/ranktable/v2/ranktable.go b/pkg/ring-controller/ranktable/v2/ranktable.go index c4850c5..0015c67 100644 --- a/pkg/ring-controller/ranktable/v2/ranktable.go +++ b/pkg/ring-controller/ranktable/v2/ranktable.go @@ -117,6 +117,5 @@ func (r *RankTable) GetPodNum() int { // DeletePod delete pod in server when pod is deleted func (r *RankTable) DeletePod(podID types.UID) { - r.Servers.Delete(podID) - // r.Servers = &sync.Map{} + r.Servers = &sync.Map{} } -- Gitee From 9e0204f3d3d613857cdae17fb477f3f45d3038cc Mon Sep 17 00:00:00 2001 From: Lianjun Zhang Atlas Date: Tue, 27 Aug 2024 13:40:29 +0000 Subject: [PATCH 4/4] test Signed-off-by: Lianjun Zhang Atlas --- pkg/ring-controller/ranktable/v2/ranktable.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/ring-controller/ranktable/v2/ranktable.go b/pkg/ring-controller/ranktable/v2/ranktable.go index 0015c67..10599f1 100644 --- a/pkg/ring-controller/ranktable/v2/ranktable.go +++ b/pkg/ring-controller/ranktable/v2/ranktable.go @@ -116,6 +116,6 @@ func (r *RankTable) GetPodNum() int { } // DeletePod delete pod in server when pod is deleted -func (r *RankTable) DeletePod(podID types.UID) { +func (r *RankTable) DeletePod(_ types.UID) { r.Servers = &sync.Map{} } -- Gitee