Skip to content

Commit 6f37b19

Browse files
enxebrepaulfantom
authored andcommitted
UPSTREAM: <carry>: openshift: Sort machines before syncing
1 parent 30ba4a7 commit 6f37b19

File tree

1 file changed

+12
-2
lines changed

1 file changed

+12
-2
lines changed

pkg/controller/machineset/controller.go

Lines changed: 12 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@ package machineset
1919
import (
2020
"context"
2121
"fmt"
22+
"sort"
2223
"strings"
2324
"sync"
2425
"time"
@@ -165,7 +166,8 @@ func (r *ReconcileMachineSet) Reconcile(request reconcile.Request) (reconcile.Re
165166
}
166167

167168
// Filter out irrelevant machines (deleting/mismatch labels) and claim orphaned machines.
168-
var filteredMachines []*machinev1beta1.Machine
169+
var machineNames []string
170+
machineSetMachines := make(map[string]*machinev1beta1.Machine)
169171
for idx := range allMachines.Items {
170172
machine := &allMachines.Items[idx]
171173
if shouldExcludeMachine(machineSet, machine) {
@@ -178,7 +180,15 @@ func (r *ReconcileMachineSet) Reconcile(request reconcile.Request) (reconcile.Re
178180
continue
179181
}
180182
}
181-
filteredMachines = append(filteredMachines, machine)
183+
machineNames = append(machineNames, machine.Name)
184+
machineSetMachines[machine.Name] = machine
185+
}
186+
// sort the filteredMachines from the oldest to the youngest
187+
sort.Strings(machineNames)
188+
189+
var filteredMachines []*machinev1beta1.Machine
190+
for _, machineName := range machineNames {
191+
filteredMachines = append(filteredMachines, machineSetMachines[machineName])
182192
}
183193

184194
syncErr := r.syncReplicas(machineSet, filteredMachines)

0 commit comments

Comments
 (0)