- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 97 for kill (0.05 sec)
-
hack/local-up-cluster.sh
if [[ -n "${KUBELET_PID-}" ]] && ! sudo kill -0 "${KUBELET_PID}" 2>/dev/null; then warning_log "kubelet terminated unexpectedly, see ${KUBELET_LOG}" KUBELET_PID= fi if [[ -n "${PROXY_PID-}" ]] && ! sudo kill -0 "${PROXY_PID}" 2>/dev/null; then warning_log "kube-proxy terminated unexpectedly, see ${PROXY_LOG}" PROXY_PID= fi if [[ -n "${SCHEDULER_PID-}" ]] && ! sudo kill -0 "${SCHEDULER_PID}" 2>/dev/null; then
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 25 02:33:52 UTC 2024 - 53.3K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_manager.go
} else { klog.V(4).InfoS("SyncPod received new pod, will create a sandbox for it", "pod", klog.KObj(pod)) } } // Step 2: Kill the pod if the sandbox has changed. if podContainerChanges.KillPod { if podContainerChanges.CreateSandbox { klog.V(4).InfoS("Stopping PodSandbox for pod, will start new one", "pod", klog.KObj(pod)) } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 22 02:01:31 UTC 2024 - 64.7K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_manager_test.go
// GetPodStatus and the following SyncPod will not return errors in the // case where the pod has been deleted. We are not adding any pods into // the fakePodProvider so they are 'deleted'. podStatus, err := m.GetPodStatus(ctx, pod.UID, pod.Name, pod.Namespace) assert.NoError(t, err) result := m.SyncPod(context.Background(), pod, podStatus, []v1.Secret{}, backOff) // This will return an error if the pod has _not_ been deleted.
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/pod_workers.go
if opts.Pod == nil || other.RunningPod == nil { opts.Pod = other.Pod } // running pods will not persist but will be remembered for replay opts.RunningPod = other.RunningPod // if mirrorPod was not provided, remember the last one for replay if other.MirrorPod != nil { opts.MirrorPod = other.MirrorPod } // accumulate kill pod options if other.KillPodOptions != nil { opts.KillPodOptions = &KillPodOptions{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 02 13:22:37 UTC 2024 - 74.8K bytes - Viewed (0) -
pkg/kubelet/pod_workers_test.go
return } for i := 0; i < numPods; i++ { uid := types.UID(strconv.Itoa(i)) // each pod should be processed two or three times (kill,terminate or create,kill,terminate) because // we buffer pending updates and the pod worker may compress the create and kill syncPodRecords := processed[uid] var match bool grace := int64(30) for _, possible := range [][]syncPodRecord{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller.go
continue } dsc.failedPodsBackoff.Next(backoffKey, now) msg := fmt.Sprintf("Found failed daemon pod %s/%s on node %s, will try to kill it", pod.Namespace, pod.Name, node.Name) logger.V(2).Info("Found failed daemon pod on node, will try to kill it", "pod", klog.KObj(pod), "node", klog.KObj(node)) // Emit an event so that it's discoverable to users.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
src/os/os_test.go
}() // Wait for the process to be started. // (It will close its stdout when it reaches TestMain.) io.Copy(io.Discard, stdout) processKiller(cmd.Process) } func TestKillStartProcess(t *testing.T) { testKillProcess(t, func(p *Process) { err := p.Kill() if err != nil { t.Fatalf("Failed to kill test process: %v", err) } }) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 83.1K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container.go
// if more precise output ordering is ever required. return append(stdout, stderr...), err } // removeContainer removes the container and the container logs. // Notice that we remove the container logs first, so that container will not be removed if // container logs are failed to be removed, and kubelet will retry this later. This guarantees
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 54.7K bytes - Viewed (0) -
cluster/gce/windows/k8s-node-setup.psm1
# Windows node, the reverse SNAT will be applied and the source address of # the packet gets replaced from the pod IP to the service VIP. The packet # will then leave the VM and return back through hairpinning. # # When IP alias is enabled, IP forwarding is disabled for anti-spoofing; # the packet with the service VIP will get blocked and be lost. With this # route, the packet will be routed to the pod subnetwork, and not leave the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 21:13:22 UTC 2024 - 88.3K bytes - Viewed (0) -
src/syscall/zsyscall_darwin_arm64.go
// THIS FILE IS GENERATED BY THE COMMAND AT THE TOP; DO NOT EDIT func kill(pid int, signum int, posix int) (err error) { _, _, e1 := syscall(abi.FuncPCABI0(libc_kill_trampoline), uintptr(pid), uintptr(signum), uintptr(posix)) if e1 != 0 { err = errnoErr(e1) } return } func libc_kill_trampoline() //go:cgo_import_dynamic libc_kill kill "/usr/lib/libSystem.B.dylib"
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Nov 27 21:34:30 UTC 2023 - 51.7K bytes - Viewed (0)