Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for pidStatus (0.13 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. src/os/exec.go

    		if !p.state.CompareAndSwap(refs, new) {
    			continue
    		}
    		if new&^processStatusMask == 0 {
    			p.closeHandle()
    		}
    		return status
    	}
    }
    
    func (p *Process) pidStatus() processStatus {
    	if p.mode != modePID {
    		panic("pidStatus called in invalid mode")
    	}
    
    	return processStatus(p.state.Load())
    }
    
    func (p *Process) pidDeactivate(reason processStatus) {
    	if p.mode != modePID {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 10 22:06:47 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  4. pkg/kubelet/kuberuntime/kuberuntime_manager_test.go

    	makeAndSetFakePod(t, m, fakeRuntime, pod)
    
    	podStatus, err := m.GetPodStatus(ctx, pod.UID, pod.Name, pod.Namespace)
    	assert.NoError(t, err)
    	assert.Equal(t, pod.UID, podStatus.ID)
    	assert.Equal(t, pod.Name, podStatus.Name)
    	assert.Equal(t, pod.Namespace, podStatus.Namespace)
    	assert.Equal(t, apitest.FakePodSandboxIPs, podStatus.IPs)
    }
    
    func TestStopContainerWithNotFoundError(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 96K bytes
    - Viewed (0)
  5. pkg/kubelet/kubelet_test.go

    		},
    	}
    	pods := []*v1.Pod{pod}
    	kl.podManager.SetPods(pods)
    	podStatus := &kubecontainer.PodStatus{ID: pod.UID}
    	gracePeriodOverride := int64(0)
    	err := kl.SyncTerminatingPod(context.Background(), pod, podStatus, &gracePeriodOverride, func(podStatus *v1.PodStatus) {
    		podStatus.Phase = v1.PodFailed
    		podStatus.Reason = "reason"
    		podStatus.Message = "message"
    	})
    	require.NoError(t, err)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  6. pilot/pkg/serviceregistry/kube/controller/ambient/workloads_test.go

    				Spec: v1.PodSpec{},
    				Status: v1.PodStatus{
    					Phase: v1.PodPending,
    				},
    			},
    			result: nil,
    		},
    		{
    			name:   "simple pod not running but have podIP",
    			inputs: []any{},
    			pod: &v1.Pod{
    				TypeMeta: metav1.TypeMeta{},
    				ObjectMeta: metav1.ObjectMeta{
    					Name:      "name",
    					Namespace: "ns",
    				},
    				Spec: v1.PodSpec{},
    				Status: v1.PodStatus{
    					Phase: v1.PodPending,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 16:51:29 UTC 2024
    - 20.3K bytes
    - Viewed (0)
  7. pkg/kubelet/kubelet_pods.go

    }
    
    // convertStatusToAPIStatus initialize an api PodStatus for the given pod from
    // the given internal pod status and the previous state of the pod from the API.
    // It is purely transformative and does not alter the kubelet state at all.
    func (kl *Kubelet) convertStatusToAPIStatus(pod *v1.Pod, podStatus *kubecontainer.PodStatus, oldPodStatus v1.PodStatus) *v1.PodStatus {
    	var apiPodStatus v1.PodStatus
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  8. pkg/kubelet/kubelet.go

    		podStatus.IPs = append(podStatus.IPs, ipInfo.IP)
    	}
    	if len(podStatus.IPs) == 0 && len(apiPodStatus.PodIP) > 0 {
    		podStatus.IPs = []string{apiPodStatus.PodIP}
    	}
    
    	// If the pod is terminal, we don't need to continue to setup the pod
    	if apiPodStatus.Phase == v1.PodSucceeded || apiPodStatus.Phase == v1.PodFailed {
    		kl.statusManager.SetPodStatus(pod, apiPodStatus)
    		isTerminal = true
    		return isTerminal, nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  9. pkg/printers/internalversion/printers_test.go

    			// Test name, num of containers, restarts, container ready status
    			api.Pod{
    				ObjectMeta: metav1.ObjectMeta{Name: "test1"},
    				Spec:       api.PodSpec{Containers: make([]api.Container, 2)},
    				Status: api.PodStatus{
    					Phase: "podPhase",
    					ContainerStatuses: []api.ContainerStatus{
    						{Ready: true, RestartCount: 3, State: api.ContainerState{Running: &api.ContainerStateRunning{}}},
    						{RestartCount: 3},
    					},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 218.6K bytes
    - Viewed (0)
  10. pkg/controller/podgc/gc_controller_test.go

    				pods = append(pods, &v1.Pod{
    					ObjectMeta: metav1.ObjectMeta{Name: pod.name, Namespace: metav1.NamespaceDefault, CreationTimestamp: metav1.Time{Time: creationTime}},
    					Status:     v1.PodStatus{Phase: pod.phase, Reason: pod.reason},
    					Spec:       v1.PodSpec{NodeName: "node"},
    				})
    			}
    			client := setupNewSimpleClient(nodes, pods)
    			gcc, podInformer, _ := NewFromClient(ctx, client, test.threshold)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 08:16:48 UTC 2024
    - 29K bytes
    - Viewed (0)
Back to top