- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for pidStatus (0.21 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)