Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for pidStatus (0.17 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/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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. pkg/kube/krt/join_test.go

    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "svc",
    			Namespace: "namespace",
    		},
    		Spec: corev1.ServiceSpec{Selector: map[string]string{"app": "foo"}},
    	}
    	sc.Create(svc)
    
    	pod.Status = corev1.PodStatus{PodIP: "1.2.3.4"}
    	pc.UpdateStatus(pod)
    
    	assert.EventuallyEqual(t, fetch, []SimpleEndpoint{
    		{pod.Name, svc.Name, pod.Namespace, "1.2.3.4"},
    		{"name-static", svc.Name, pod.Namespace, "9.9.9.9"},
    	})
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 09 19:55:53 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  9. cni/pkg/nodeagent/cni-watcher_test.go

    	defer cancel()
    	pod := &corev1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "pod-bingo",
    			Namespace: "funkyns",
    		},
    		Spec: corev1.PodSpec{
    			NodeName: NodeName,
    		},
    		Status: corev1.PodStatus{
    			PodIP: fakePodIP,
    		},
    	}
    	ns := &corev1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: "funkyns"}}
    
    	client := kube.NewFakeClient(ns, pod)
    
    	// We are expecting at most 1 calls to the mock, wait for them
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 21:31:35 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/apis/example/v1/generated.proto

      // If not specified, the pod will be dispatched by default scheduler.
      // +optional
      optional string schedulername = 19;
    }
    
    // PodStatus represents information about the status of a pod. Status may trail the actual
    // state of a system.
    message PodStatus {
      // Current condition of the pod.
      // More info: http://kubernetes.io/docs/user-guide/pod-states#pod-phase
      // +optional
      optional string phase = 1;
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 28 15:34:11 UTC 2024
    - 7.6K bytes
    - Viewed (0)
Back to top