Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 34 for pidStatus (0.16 sec)

  1. src/os/exec_plan9.go

    	if e != nil {
    		return e
    	}
    	defer f.Close()
    	_, e = f.Write([]byte(data))
    	return e
    }
    
    func (p *Process) signal(sig Signal) error {
    	switch p.pidStatus() {
    	case statusDone:
    		return ErrProcessDone
    	case statusReleased:
    		return syscall.ENOENT
    	}
    
    	if e := p.writeProcFile("note", sig.String()); e != nil {
    		return NewSyscallError("signal", e)
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 10 22:06:47 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  2. src/os/exec_unix.go

    	// completes its wait.
    	//
    	// Checking for statusDone here would not be a complete fix, as the PID
    	// could still be waited on and reused prior to blockUntilWaitable.
    	switch p.pidStatus() {
    	case statusReleased:
    		return nil, syscall.EINVAL
    	}
    
    	// If we can block until Wait4 will succeed immediately, do so.
    	ready, err := p.blockUntilWaitable()
    	if err != nil {
    		return nil, err
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 10 22:06:47 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  3. pkg/kubelet/container/cache.go

    // and the blocking GetNewerThan() method. The component responsible for
    // populating the cache is expected to call Delete() to explicitly free the
    // cache entries.
    type Cache interface {
    	Get(types.UID) (*PodStatus, error)
    	// Set updates the cache by setting the PodStatus for the pod only
    	// if the data is newer than the cache based on the provided
    	// time stamp. Returns if the cache was updated.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 17 07:37:01 UTC 2023
    - 6.6K bytes
    - Viewed (0)
  4. pkg/kubelet/kuberuntime/util/util_test.go

    	for desc, test := range map[string]struct {
    		pod               *v1.Pod
    		status            *kubecontainer.PodStatus
    		expectedChanged   bool
    		expectedAttempt   uint32
    		expectedSandboxID string
    	}{
    		"Pod with no existing sandboxes": {
    			pod:               &v1.Pod{},
    			status:            &kubecontainer.PodStatus{},
    			expectedChanged:   true,
    			expectedAttempt:   0,
    			expectedSandboxID: "",
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 13 23:14:48 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  5. pkg/controller/job/pod_failure_policy.go

    func matchOnExitCodes(podStatus *v1.PodStatus, requirement *batch.PodFailurePolicyOnExitCodesRequirement) *v1.ContainerStatus {
    	if containerStatus := getMatchingContainerFromList(podStatus.ContainerStatuses, requirement); containerStatus != nil {
    		return containerStatus
    	}
    	return getMatchingContainerFromList(podStatus.InitContainerStatuses, requirement)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 18 20:44:11 UTC 2023
    - 5.5K bytes
    - Viewed (0)
  6. pkg/controller/deployment/recreate_test.go

    			podMap: map[types.UID][]*v1.Pod{
    				"uid-1": {
    					{
    						Status: v1.PodStatus{
    							Phase: v1.PodFailed,
    						},
    					},
    					{
    						Status: v1.PodStatus{
    							Phase: v1.PodSucceeded,
    						},
    					},
    				},
    				"uid-2": {},
    				"uid-3": {
    					{
    						Status: v1.PodStatus{
    							Phase: v1.PodPending,
    						},
    					},
    				},
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 08 09:10:50 UTC 2023
    - 5.9K bytes
    - Viewed (0)
  7. pkg/kubelet/kuberuntime/util/util.go

    // (changed, new attempt, original sandboxID if exist).
    func PodSandboxChanged(pod *v1.Pod, podStatus *kubecontainer.PodStatus) (bool, uint32, string) {
    	if len(podStatus.SandboxStatuses) == 0 {
    		klog.V(2).InfoS("No sandbox for pod can be found. Need to start a new one", "pod", klog.KObj(pod))
    		return true, 0, ""
    	}
    
    	readySandboxCount := 0
    	for _, s := range podStatus.SandboxStatuses {
    		if s.State == runtimeapi.PodSandboxState_SANDBOX_READY {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 13 23:14:48 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  8. pkg/kubelet/runonce_test.go

    	podManager.SetPods(pods)
    	// The original test here is totally meaningless, because fakeruntime will always return an empty podStatus. While
    	// the original logic of isPodRunning happens to return true when podstatus is empty, so the test can always pass.
    	// Now the logic in isPodRunning is changed, to let the test pass, we set the podstatus directly in fake runtime.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 06:59:54 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  9. pkg/kube/krt/index_test.go

    		})
    	}
    
    	SimplePods.Register(TrackerHandler[SimplePod](tt))
    
    	pod := &corev1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "name",
    			Namespace: "namespace",
    		},
    		Status: corev1.PodStatus{PodIP: "1.2.3.4"},
    	}
    	pc.CreateOrUpdateStatus(pod)
    	tt.WaitUnordered("add/namespace/name")
    	assert.Equal(t, fetchSorted("1.2.3.4"), []SimplePod{{NewNamed(pod), Labeled{}, "1.2.3.4"}})
    
    	pod.Status.PodIP = "1.2.3.5"
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 09 19:55:53 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  10. cni/pkg/util/podutil_test.go

    	pod := &corev1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "test",
    			Namespace: "test",
    		},
    		Spec: corev1.PodSpec{
    			NodeName: "derp",
    		},
    		Status: corev1.PodStatus{
    			PodIP: "11.1.1.12",
    		},
    	}
    
    	podIPs := GetPodIPsIfPresent(pod)
    	assert.Equal(t, len(podIPs), 1)
    }
    
    func TestGetPodIPsIfPodIPPresent(t *testing.T) {
    	pod := &corev1.Pod{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 03 19:29:42 UTC 2024
    - 4.9K bytes
    - Viewed (0)
Back to top