Skip to content

Commit d0fb90c

Browse files
enxebreingvagabund
authored andcommitted
UPSTREAM: <carry>: openshift: Sort machines before syncing
1 parent c745a34 commit d0fb90c

File tree

1 file changed

+11
-2
lines changed

1 file changed

+11
-2
lines changed

pkg/controller/machineset/controller.go

Lines changed: 11 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"
@@ -225,7 +226,8 @@ func (r *ReconcileMachineSet) reconcile(ctx context.Context, machineSet *machine
225226
}
226227

227228
// Filter out irrelevant machines (deleting/mismatch labels) and claim orphaned machines.
228-
filteredMachines := make([]*machinev1beta1.Machine, 0, len(allMachines.Items))
229+
var machineNames []string
230+
machineSetMachines := make(map[string]*machinev1beta1.Machine)
229231
for idx := range allMachines.Items {
230232
machine := &allMachines.Items[idx]
231233
if shouldExcludeMachine(machineSet, machine) {
@@ -239,8 +241,15 @@ func (r *ReconcileMachineSet) reconcile(ctx context.Context, machineSet *machine
239241
continue
240242
}
241243
}
244+
machineNames = append(machineNames, machine.Name)
245+
machineSetMachines[machine.Name] = machine
246+
}
247+
// sort the filteredMachines from the oldest to the youngest
248+
sort.Strings(machineNames)
242249

243-
filteredMachines = append(filteredMachines, machine)
250+
var filteredMachines []*machinev1beta1.Machine
251+
for _, machineName := range machineNames {
252+
filteredMachines = append(filteredMachines, machineSetMachines[machineName])
244253
}
245254

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

0 commit comments

Comments
 (0)