Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for ClearState (0.14 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top