Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 1,536 for pcds (0.05 sec)

  1. pkg/kubelet/cm/container_manager_linux.go

    		for _, pid := range allPids {
    			if pid == 1 || isKernelPid(pid) {
    				continue
    			}
    
    			pids = append(pids, pid)
    		}
    
    		// Check if we have moved all the non-kernel PIDs.
    		if len(pids) == 0 {
    			return nil
    		}
    
    		klog.V(3).InfoS("Moving non-kernel processes", "pids", pids)
    		for _, pid := range pids {
    			err := manager.Apply(pid)
    			if err != nil {
    				name := ""
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 10:18:16 UTC 2024
    - 35.1K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/node_container_manager_linux.go

    		nodeAllocatable = cm.getNodeAllocatableInternalAbsolute()
    	}
    
    	cgroupConfig := &CgroupConfig{
    		Name: cm.cgroupRoot,
    		// The default limits for cpu shares can be very low which can lead to CPU starvation for pods.
    		ResourceParameters: getCgroupConfig(nodeAllocatable),
    	}
    	if cm.cgroupManager.Exists(cgroupConfig.Name) {
    		return nil
    	}
    	if err := cm.cgroupManager.Create(cgroupConfig); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 10:18:16 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/endpoints/request/requestinfo_test.go

    		{"GET", "/api/v1/watch/namespaces/other/pods", "watch", "api", "", "v1", "other", "pods", "", "", []string{"pods"}},
    		{"GET", "/api/v1/namespaces/other/pods?watch=1", "watch", "api", "", "v1", "other", "pods", "", "", []string{"pods"}},
    		{"GET", "/api/v1/namespaces/other/pods?watch=0", "list", "api", "", "v1", "other", "pods", "", "", []string{"pods"}},
    
    		// subresource identification
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 15 12:19:21 UTC 2018
    - 11.3K bytes
    - Viewed (0)
  4. pkg/controller/statefulset/stateful_set_control_test.go

    		}
    
    		sort.Sort(ascendingOrdinal(pods))
    
    		// expected number of pod is 0,1,2,3
    		if !reflect.DeepEqual(pods, originalPods[:4]) {
    			t.Fatalf("Expected pods %v, got pods %v", originalPods[:4], pods)
    		}
    
    		// create new pods
    		if _, err = ssc.UpdateStatefulSet(context.TODO(), set, pods); err != nil {
    			t.Fatal(err)
    		}
    		pods, err = spc.podsLister.Pods(set.Namespace).List(selector)
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 07 19:01:47 UTC 2024
    - 108.7K bytes
    - Viewed (0)
  5. pkg/kubelet/eviction/eviction_manager_test.go

    			summaryStatsMaker := makePIDStats
    			pods := []*v1.Pod{}
    			podStats := map[*v1.Pod]statsapi.PodStats{}
    			for _, podToMake := range tc.podsToMake {
    				pod, podStat := podMaker(podToMake.name, podToMake.priority, podToMake.pidUsage)
    				pods = append(pods, pod)
    				podStats[pod] = podStat
    			}
    			podToEvict := pods[tc.evictPodIndex]
    			activePodsFunc := func() []*v1.Pod { return pods }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 15 23:14:12 UTC 2024
    - 119.9K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/watch_tracker_test.go

    		httpRequest("GET", "api/v1/pods", "watch=true"),
    		httpRequest("GET", "api/v1/namespaces/foo/pods", "watch=true"),
    		httpRequest("GET", "api/v1/namespaces/foo/pods", "watch=true&fieldSelector=metadata.name=mypod"),
    		httpRequest("GET", "api/v1/namespaces/bar/pods", "watch=true&fieldSelector=metadata.name=mypod"),
    		httpRequest("GET", "apis/group/v1/namespaces/foo/pods", "watch=true"),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 03 14:02:51 UTC 2021
    - 10.4K bytes
    - Viewed (0)
  7. pkg/kubelet/active_deadline_test.go

    	// this pod has no start time
    	pods[3].Status.StartTime = nil
    	pods[3].Spec.ActiveDeadlineSeconds = &notYetActiveDeadlineSeconds
    
    	testCases := []struct {
    		pod      *v1.Pod
    		expected bool
    	}{{pods[0], true}, {pods[1], false}, {pods[2], false}, {pods[3], false}, {pods[4], false}}
    
    	for i, testCase := range testCases {
    		if actual := handler.ShouldSync(testCase.pod); actual != testCase.expected {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Oct 08 09:06:42 UTC 2022
    - 4.5K bytes
    - Viewed (0)
  8. pkg/controller/podgc/gc_controller_test.go

    			creationTime := time.Unix(0, 0)
    			nodes := []*v1.Node{testutil.NewNode("node")}
    
    			pods := make([]*v1.Pod, 0, len(test.pods))
    			for _, pod := range test.pods {
    				creationTime = creationTime.Add(1 * time.Hour)
    				pods = append(pods, &v1.Pod{
    					ObjectMeta: metav1.ObjectMeta{Name: pod.name, Namespace: metav1.NamespaceDefault, CreationTimestamp: metav1.Time{Time: creationTime}},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 08:16:48 UTC 2024
    - 29K bytes
    - Viewed (0)
  9. pkg/kubelet/preemption/preemption.go

    		podsToEvict = append(podsToEvict, pods[bestPodIndex])
    		pods[bestPodIndex] = pods[len(pods)-1]
    		pods = pods[:len(pods)-1]
    	}
    	return podsToEvict, nil
    }
    
    type admissionRequirement struct {
    	resourceName v1.ResourceName
    	quantity     int64
    }
    
    type admissionRequirementList []*admissionRequirement
    
    // distance returns distance of the pods requests from the admissionRequirements.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 02 16:53:19 UTC 2023
    - 11.5K bytes
    - Viewed (0)
  10. staging/src/k8s.io/api/policy/v1beta1/types.go

    	// A null selector selects no pods.
    	// An empty selector ({}) also selects no pods, which differs from standard behavior of selecting all pods.
    	// In policy/v1, an empty selector will select all pods in the namespace.
    	// +optional
    	Selector *metav1.LabelSelector `json:"selector,omitempty" protobuf:"bytes,2,opt,name=selector"`
    
    	// An eviction is allowed if at most "maxUnavailable" pods selected by
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Aug 07 20:44:13 UTC 2023
    - 11.1K bytes
    - Viewed (0)
Back to top