Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for pidStatus (0.21 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_pods_test.go

    				pod.Status.PodIP = pod.Status.PodIPs[0].IP
    			}
    
    			// set old status
    			podStatus := &kubecontainer.PodStatus{
    				ID:        pod.UID,
    				Name:      pod.Name,
    				Namespace: pod.Namespace,
    			}
    			podStatus.IPs = tc.nodeIPs
    
    			status := kl.generateAPIPodStatus(pod, podStatus, false)
    			if !reflect.DeepEqual(status.PodIPs, tc.expectedPodIPs) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/informers_test.go

    	defer cancel()
    
    	pod := &corev1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "test",
    			Namespace: "test",
    		},
    		Spec: corev1.PodSpec{
    			NodeName: NodeName,
    		},
    		Status: corev1.PodStatus{
    			PodIP: "11.1.1.12",
    		},
    	}
    	ns := &corev1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: "test"}}
    
    	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 05:10:23 UTC 2024
    - 22.2K bytes
    - Viewed (0)
  7. pkg/controller/job/backoff_utils_test.go

    			newFailedPods := []*v1.Pod{}
    
    			for _, finishTime := range tc.newSucceededPods {
    				newSucceededPods = append(newSucceededPods, &v1.Pod{
    					ObjectMeta: metav1.ObjectMeta{},
    					Status: v1.PodStatus{
    						Phase: v1.PodSucceeded,
    						ContainerStatuses: []v1.ContainerStatus{
    							{
    								State: v1.ContainerState{
    									Terminated: &v1.ContainerStateTerminated{
    										FinishedAt: finishTime,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 07:46:41 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  8. 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)
  9. pkg/kubelet/container/runtime.go

    	// not managed by kubelet.
    	Hash uint64
    	// State is the state of the container.
    	State State
    }
    
    // PodStatus represents the status of the pod and its containers.
    // v1.PodStatus can be derived from examining PodStatus and v1.Pod.
    type PodStatus struct {
    	// ID of the pod.
    	ID types.UID
    	// Name of the pod.
    	Name string
    	// Namespace of the pod.
    	Namespace string
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  10. 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)
Back to top