- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for SetMachineState (0.24 sec)
-
pkg/kubelet/cm/memorymanager/state/state_checkpoint.go
sc.RLock() defer sc.RUnlock() return sc.cache.GetMemoryAssignments() } // SetMachineState stores NUMANodeMap in State func (sc *stateCheckpoint) SetMachineState(memoryMap NUMANodeMap) { sc.Lock() defer sc.Unlock() sc.cache.SetMachineState(memoryMap) err := sc.storeState() if err != nil { klog.InfoS("Store state to checkpoint error", "err", err) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 08 16:05:48 UTC 2022 - 5.3K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/state/state_mem.go
func (s *stateMemory) GetMemoryAssignments() ContainerMemoryAssignments { s.RLock() defer s.RUnlock() return s.assignments.Clone() } // SetMachineState stores NUMANodeMap in State func (s *stateMemory) SetMachineState(nodeMap NUMANodeMap) { s.Lock() defer s.Unlock() s.machineState = nodeMap.Clone() klog.InfoS("Updated machine memory state") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 15 19:51:19 UTC 2021 - 3.2K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/state/state.go
// GetMemoryAssignments returns ContainerMemoryAssignments GetMemoryAssignments() ContainerMemoryAssignments } type writer interface { // SetMachineState stores NUMANodeMap in State SetMachineState(memoryMap NUMANodeMap) // SetMemoryBlocks stores memory assignments of a container SetMemoryBlocks(podUID string, containerName string, blocks []Block)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 08 23:10:00 UTC 2021 - 4.4K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/state/state_checkpoint_test.go
assert.NoError(t, err, "could not create testing checkpointState instance") // set values of cs1 instance so they are stored in checkpoint and can be read by cs2 cs1.SetMachineState(expectedState.machineState) cs1.SetMemoryAssignments(expectedState.assignments) // restore checkpoint with previously stored values cs2, err := NewCheckpointState(testingDir, testingCheckpoint, "static")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jul 30 03:35:26 UTC 2022 - 10.6K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/memory_manager_test.go
podStatusProvider: mockPodStatusProvider{}, } mgr.sourcesReady = &sourcesReadyStub{} mgr.state.SetMemoryAssignments(testCase.assignments) mgr.state.SetMachineState(testCase.machineState) mgr.removeStaleState() if !areContainerMemoryAssignmentsEqual(t, mgr.state.GetMemoryAssignments(), testCase.expectedAssignments) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 05 13:01:40 UTC 2023 - 70.2K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/policy_static.go
} // Update nodes memory state p.updateMachineState(machineState, maskBits, resourceName, requestedSize) } p.updatePodReusableMemory(pod, container, containerBlocks) s.SetMachineState(machineState) s.SetMemoryBlocks(podUID, container.Name, containerBlocks) // update init containers memory blocks to reflect the fact that we re-used init containers memory
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Nov 12 07:34:55 UTC 2023 - 34K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/policy_static_test.go
if err != nil { return nil, nil, err } if initContainersReusableMemory != nil { p.(*staticPolicy).initContainersReusableMemory = initContainersReusableMemory } s := state.NewMemoryState() s.SetMachineState(testCase.machineState) s.SetMemoryAssignments(testCase.assignments) return p, s, nil } func newNUMAAffinity(bits ...int) bitmask.BitMask { affinity, err := bitmask.NewBitMask(bits...) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Sep 17 05:49:15 UTC 2023 - 100.4K bytes - Viewed (0)