- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for ClearState (0.14 sec)
-
pkg/kubelet/cm/memorymanager/state/state_checkpoint.go
err := sc.storeState() if err != nil { klog.InfoS("Store state to checkpoint error", "err", err) } } // ClearState clears machineState and ContainerMemoryAssignments func (sc *stateCheckpoint) ClearState() { sc.Lock() defer sc.Unlock() sc.cache.ClearState() 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
delete(s.assignments, podUID) } klog.V(2).InfoS("Deleted memory assignment", "podUID", podUID, "containerName", containerName) } // ClearState clears machineState and ContainerMemoryAssignments func (s *stateMemory) ClearState() { s.Lock() defer s.Unlock() s.machineState = NUMANodeMap{} s.assignments = make(ContainerMemoryAssignments) klog.V(2).InfoS("Cleared 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/status/state/state_checkpoint.go
sc.mux.Lock() defer sc.mux.Unlock() sc.cache.Delete(podUID, containerName) return sc.storeState() } // ClearState clears the state and saves it in a checkpoint func (sc *stateCheckpoint) ClearState() error { sc.mux.Lock() defer sc.mux.Unlock() sc.cache.ClearState() return sc.storeState() } type noopStateCheckpoint struct{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 13 00:16:44 UTC 2023 - 6.9K bytes - Viewed (0) -
pkg/kubelet/status/state/state.go
SetPodResourceAllocation(PodResourceAllocation) error SetPodResizeStatus(podUID string, resizeStatus v1.PodResizeStatus) error SetResizeStatus(PodResizeStatus) error Delete(podUID string, containerName string) error ClearState() error } // State interface provides methods for tracking and setting pod resource allocation type State interface { Reader writer
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 24 18:21:21 UTC 2023 - 2K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/state/state_checkpoint.go
err := sc.storeState() if err != nil { klog.InfoS("Store state to checkpoint error", "err", err) } } // ClearState clears the state and saves it in a checkpoint func (sc *stateCheckpoint) ClearState() { sc.mux.Lock() defer sc.mux.Unlock() sc.cache.ClearState() 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: Thu Jul 13 00:59:30 UTC 2023 - 7.9K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/state/state.go
SetMemoryAssignments(assignments ContainerMemoryAssignments) // Delete deletes corresponding Blocks from ContainerMemoryAssignments Delete(podUID string, containerName string) // ClearState clears machineState and ContainerMemoryAssignments ClearState() } // State interface provides methods for tracking and setting memory/pod assignment type State interface { Reader writer
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/cpumanager/state/state.go
type writer interface { SetCPUSet(podUID string, containerName string, cpuset cpuset.CPUSet) SetDefaultCPUSet(cpuset cpuset.CPUSet) SetCPUAssignments(ContainerCPUAssignments) Delete(podUID string, containerName string) ClearState() } // State interface provides methods for tracking and setting cpu/pod assignment type State interface { Reader writer
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 13 00:59:30 UTC 2023 - 1.7K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/state/state_mem.go
if len(s.assignments[podUID]) == 0 { delete(s.assignments, podUID) } klog.V(2).InfoS("Deleted CPUSet assignment", "podUID", podUID, "containerName", containerName) } func (s *stateMemory) ClearState() { s.Lock() defer s.Unlock() s.defaultCPUSet = cpuset.CPUSet{} s.assignments = make(ContainerCPUAssignments) klog.V(2).InfoS("Cleared state")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 2.9K bytes - Viewed (0) -
pkg/kubelet/status/state/state_mem.go
klog.V(3).InfoS("Deleted pod resource allocation and resize state", "podUID", podUID) return nil } s.deleteContainer(podUID, containerName) return nil } func (s *stateMemory) ClearState() error { s.Lock() defer s.Unlock() s.podAllocation = make(PodResourceAllocation) s.podResizeStatus = make(PodResizeStatus) klog.V(3).InfoS("Cleared state") return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 24 18:21:21 UTC 2023 - 4K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/state/state_checkpoint_test.go
assert.NoError(t, err, "could not create testing checkpoint manager") state.SetMachineState(tc.machineState) state.SetMemoryAssignments(tc.assignments) state.ClearState() assert.Equal(t, NUMANodeMap{}, state.GetMachineState(), "cleared state with non-empty machine state")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jul 30 03:35:26 UTC 2022 - 10.6K bytes - Viewed (0)