Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for GetCPUSet (0.12 sec)

  1. pkg/kubelet/cm/cpumanager/state/state_mem.go

    func NewMemoryState() State {
    	klog.InfoS("Initialized new in-memory state store")
    	return &stateMemory{
    		assignments:   ContainerCPUAssignments{},
    		defaultCPUSet: cpuset.New(),
    	}
    }
    
    func (s *stateMemory) GetCPUSet(podUID string, containerName string) (cpuset.CPUSet, bool) {
    	s.RLock()
    	defer s.RUnlock()
    
    	res, ok := s.assignments[podUID][containerName]
    	return res.Clone(), ok
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/cpumanager/state/state_checkpoint.go

    	if err != nil {
    		klog.ErrorS(err, "Failed to save checkpoint")
    		return err
    	}
    	return nil
    }
    
    // GetCPUSet returns current CPU set
    func (sc *stateCheckpoint) GetCPUSet(podUID string, containerName string) (cpuset.CPUSet, bool) {
    	sc.mux.RLock()
    	defer sc.mux.RUnlock()
    
    	res, ok := sc.cache.GetCPUSet(podUID, containerName)
    	return res, ok
    }
    
    // GetDefaultCPUSet returns default CPU set
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jul 13 00:59:30 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/cpumanager/state/state_checkpoint_test.go

    				for container, set := range tc.assignments[pod] {
    					state.SetCPUSet(pod, container, set)
    					if cpus, _ := state.GetCPUSet(pod, container); !cpus.Equals(set) {
    						t.Fatalf("state inconsistent, got %q instead of %q", set, cpus)
    					}
    
    					state.Delete(pod, container)
    					if _, ok := state.GetCPUSet(pod, container); ok {
    						t.Fatal("deleted container still existing in state")
    					}
    				}
    			}
    		})
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 10.9K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/cpumanager/state/state.go

    		for container, cset := range as[pod] {
    			ret[pod][container] = cset
    		}
    	}
    	return ret
    }
    
    // Reader interface used to read current cpu/pod assignment state
    type Reader interface {
    	GetCPUSet(podUID string, containerName string) (cpuset.CPUSet, bool)
    	GetDefaultCPUSet() cpuset.CPUSet
    	GetCPUSetOrDefault(podUID string, containerName string) cpuset.CPUSet
    	GetCPUAssignments() ContainerCPUAssignments
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jul 13 00:59:30 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/cpumanager/policy_static.go

    			return SMTAlignmentError{
    				RequestedCPUs:         numCPUs,
    				CpusPerCore:           CPUsPerCore,
    				AvailablePhysicalCPUs: availablePhysicalCPUs,
    			}
    		}
    	}
    	if cpuset, ok := s.GetCPUSet(string(pod.UID), container.Name); ok {
    		p.updateCPUsToReuse(pod, container, cpuset)
    		klog.InfoS("Static policy: container already present in state, skipping", "pod", klog.KObj(pod), "containerName", container.Name)
    		return nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 06 13:16:15 UTC 2023
    - 28.8K bytes
    - Viewed (0)
  6. pkg/kubelet/cm/cpumanager/cpu_manager.go

    		return err
    	}
    
    	return nil
    }
    
    func (m *manager) AddContainer(pod *v1.Pod, container *v1.Container, containerID string) {
    	m.Lock()
    	defer m.Unlock()
    	if cset, exists := m.state.GetCPUSet(string(pod.UID), container.Name); exists {
    		m.lastUpdateState.SetCPUSet(string(pod.UID), container.Name, cset)
    	}
    	m.containerMap.Add(string(pod.UID), container.Name, containerID)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 19.9K bytes
    - Viewed (0)
  7. pkg/kubelet/cm/cpumanager/cpu_manager_test.go

    }
    
    func (s *mockState) GetCPUSet(podUID string, containerName string) (cpuset.CPUSet, bool) {
    	res, ok := s.assignments[podUID][containerName]
    	return res.Clone(), ok
    }
    
    func (s *mockState) GetDefaultCPUSet() cpuset.CPUSet {
    	return s.defaultCPUSet.Clone()
    }
    
    func (s *mockState) GetCPUSetOrDefault(podUID string, containerName string) cpuset.CPUSet {
    	if res, ok := s.GetCPUSet(podUID, containerName); ok {
    		return res
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 06 13:16:15 UTC 2023
    - 42.9K bytes
    - Viewed (0)
Back to top