Skip to content

Commit 71e292c

Browse files
committed
Don't update cluster state if nothing changed
1 parent 1b97e67 commit 71e292c

File tree

1 file changed

+10
-2
lines changed

1 file changed

+10
-2
lines changed

pkg/flypg/state/cluster.go

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -81,11 +81,19 @@ func (c *ClusterState) UnregisterMember(id int32) error {
8181
}
8282

8383
// Rebuild the members slice and exclude the target member.
84+
exists := false
8485
var members []*Member
8586
for _, member := range cluster.Members {
86-
if member.ID != id {
87-
members = append(members, member)
87+
if member.ID == id {
88+
exists = true
89+
continue
8890
}
91+
92+
members = append(members, member)
93+
}
94+
95+
if !exists {
96+
return nil
8997
}
9098

9199
cluster.Members = members

0 commit comments

Comments
 (0)