Skip to content

Commit d64f34e

Browse files
committed
memorymanager: areMemoryStatesEqual helper
perform the memoryStates comparison in helper function Signed-off-by: Talor Itzhak <[email protected]>
1 parent 7476f46 commit d64f34e

File tree

1 file changed

+19
-12
lines changed

1 file changed

+19
-12
lines changed

pkg/kubelet/cm/memorymanager/policy_static.go

Lines changed: 19 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -681,18 +681,7 @@ func areMachineStatesEqual(ms1, ms2 state.NUMANodeMap) bool {
681681
return false
682682
}
683683

684-
if memoryState1.TotalMemSize != memoryState2.TotalMemSize {
685-
klog.ErrorS(nil, "Memory states for the NUMA node and resource are different", "node", nodeID, "resource", resourceName, "field", "TotalMemSize", "TotalMemSize1", memoryState1.TotalMemSize, "TotalMemSize2", memoryState2.TotalMemSize, "memoryState1", *memoryState1, "memoryState2", *memoryState2)
686-
return false
687-
}
688-
689-
if memoryState1.SystemReserved != memoryState2.SystemReserved {
690-
klog.ErrorS(nil, "Memory states for the NUMA node and resource are different", "node", nodeID, "resource", resourceName, "field", "SystemReserved", "SystemReserved1", memoryState1.SystemReserved, "SystemReserved2", memoryState2.SystemReserved, "memoryState1", *memoryState1, "memoryState2", *memoryState2)
691-
return false
692-
}
693-
694-
if memoryState1.Allocatable != memoryState2.Allocatable {
695-
klog.ErrorS(nil, "Memory states for the NUMA node and resource are different", "node", nodeID, "resource", resourceName, "field", "Allocatable", "Allocatable1", memoryState1.Allocatable, "Allocatable2", memoryState2.Allocatable, "memoryState1", *memoryState1, "memoryState2", *memoryState2)
684+
if !areMemoryStatesEqual(memoryState1, memoryState2, nodeID, resourceName) {
696685
return false
697686
}
698687

@@ -718,6 +707,24 @@ func areMachineStatesEqual(ms1, ms2 state.NUMANodeMap) bool {
718707
return true
719708
}
720709

710+
func areMemoryStatesEqual(memoryState1, memoryState2 *state.MemoryTable, nodeID int, resourceName v1.ResourceName) bool {
711+
if memoryState1.TotalMemSize != memoryState2.TotalMemSize {
712+
klog.ErrorS(nil, "Memory states for the NUMA node and resource are different", "node", nodeID, "resource", resourceName, "field", "TotalMemSize", "TotalMemSize1", memoryState1.TotalMemSize, "TotalMemSize2", memoryState2.TotalMemSize, "memoryState1", *memoryState1, "memoryState2", *memoryState2)
713+
return false
714+
}
715+
716+
if memoryState1.SystemReserved != memoryState2.SystemReserved {
717+
klog.ErrorS(nil, "Memory states for the NUMA node and resource are different", "node", nodeID, "resource", resourceName, "field", "SystemReserved", "SystemReserved1", memoryState1.SystemReserved, "SystemReserved2", memoryState2.SystemReserved, "memoryState1", *memoryState1, "memoryState2", *memoryState2)
718+
return false
719+
}
720+
721+
if memoryState1.Allocatable != memoryState2.Allocatable {
722+
klog.ErrorS(nil, "Memory states for the NUMA node and resource are different", "node", nodeID, "resource", resourceName, "field", "Allocatable", "Allocatable1", memoryState1.Allocatable, "Allocatable2", memoryState2.Allocatable, "memoryState1", *memoryState1, "memoryState2", *memoryState2)
723+
return false
724+
}
725+
return true
726+
}
727+
721728
func (p *staticPolicy) getDefaultMachineState() state.NUMANodeMap {
722729
defaultMachineState := state.NUMANodeMap{}
723730
nodeHugepages := map[int]uint64{}

0 commit comments

Comments
 (0)