- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 68 for pidStatus (0.18 sec)
-
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) -
staging/src/k8s.io/client-go/applyconfigurations/core/v1/podstatus.go
ResourceClaimStatuses []PodResourceClaimStatusApplyConfiguration `json:"resourceClaimStatuses,omitempty"` } // PodStatusApplyConfiguration constructs an declarative configuration of the PodStatus type for use with // apply. func PodStatus() *PodStatusApplyConfiguration { return &PodStatusApplyConfiguration{} } // WithPhase sets the Phase field in the declarative configuration to the given value
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 14 01:43:16 UTC 2023 - 10.5K bytes - Viewed (0) -
pkg/apis/core/v1/conversion_test.go
t.Errorf("%v: Convert core.PodStatus to v1.PodStatus failed. Expected v1.PodStatus[%v]=%v but found %v", i, idx, input.PodIPs[idx].IP, v1PodStatus.PodIPs[idx].IP) } } } } func Test_v1_PodStatus_to_core_PodStatus(t *testing.T) { asymmetricInputs := []struct { name string in v1.PodStatus out core.PodStatus }{ { name: "mismatched podIP", in: v1.PodStatus{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 10 05:34:15 UTC 2023 - 21.7K bytes - Viewed (0) -
pkg/controller/job/pod_failure_policy_test.go
Operator: batch.PodFailurePolicyOnExitCodesOpIn, Values: []int32{2, 3}, }, }, }, }, failedPod: &v1.Pod{ ObjectMeta: validPodObjectMeta, Status: v1.PodStatus{ Phase: v1.PodFailed, ContainerStatuses: []v1.ContainerStatus{ { Name: "main-container", State: v1.ContainerState{ Terminated: &v1.ContainerStateTerminated{ ExitCode: 2,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 22.7K bytes - Viewed (0) -
pkg/kubelet/pleg/evented.go
func (e *EventedPLEG) updateRunningPodMetric(podStatus *kubecontainer.PodStatus) { cachedPodStatus, err := e.cache.Get(podStatus.ID) if err != nil { klog.ErrorS(err, "Evented PLEG: Get cache", "podID", podStatus.ID) } // cache miss condition: The pod status object will have empty state if missed in cache if len(cachedPodStatus.SandboxStatuses) < 1 { sandboxState := getPodSandboxState(podStatus)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 10:46:06 UTC 2024 - 16.4K bytes - Viewed (0) -
pkg/api/v1/pod/util_test.go
LastTransitionTime: metav1.NewTime(time.Add(1000)), } tests := []struct { desc string podStatus v1.PodStatus expectedCondition *v1.PodCondition }{ { desc: "containers ready condition exists", podStatus: v1.PodStatus{ Conditions: []v1.PodCondition{containersReadyCondition}, }, expectedCondition: &containersReadyCondition, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 25 11:04:08 UTC 2023 - 32.1K bytes - Viewed (0) -
pkg/kubelet/prober/prober_manager.go
} // there is no startup probe, so the container is started. return true } func (m *manager) UpdatePodStatus(pod *v1.Pod, podStatus *v1.PodStatus) { for i, c := range podStatus.ContainerStatuses { started := m.isContainerStarted(pod, &podStatus.ContainerStatuses[i]) podStatus.ContainerStatuses[i].Started = &started if !started { continue } var ready bool if c.State.Running == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 07 22:26:12 UTC 2023 - 11K bytes - Viewed (0) -
pkg/kubelet/container/helpers.go
// ConvertPodStatusToRunningPod returns Pod given PodStatus and container runtime string. // TODO(random-liu): Convert PodStatus to running Pod, should be deprecated soon func ConvertPodStatusToRunningPod(runtimeName string, podStatus *PodStatus) Pod { runningPod := Pod{ ID: podStatus.ID, Name: podStatus.Name, Namespace: podStatus.Namespace, } for _, containerStatus := range podStatus.ContainerStatuses {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.3K bytes - Viewed (0) -
pkg/api/pod/util.go
dropUserField(podStatus.ContainerStatuses) dropUserField(podStatus.EphemeralContainerStatuses) } } func hostIPsInUse(podStatus *api.PodStatus) bool { if podStatus == nil { return false } return len(podStatus.HostIPs) > 0 } // dropDisabledDynamicResourceAllocationFields removes pod claim references from // container specs and pod-level resource claims unless they are already used
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 41.3K bytes - Viewed (0) -
pkg/kubelet/prober/worker_test.go
}, }, { // Pod failed podStatus: &failedStatus, }, { // Pod deletion podStatus: &runningStatus, setDeletionTimestamp: true, expectSet: true, expectContinue: map[string]bool{ readiness.String(): true, }, expectedResult: results.Success, }, { // No container status podStatus: &otherStatus, expectContinue: map[string]bool{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 07 23:48:10 UTC 2023 - 16.1K bytes - Viewed (0)