- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 132 for preemptee (0.13 sec)
-
pkg/kubelet/types/pod_update.go
} // Preemptable returns true if preemptor pod can preempt preemptee pod // if preemptee is not critical or if preemptor's priority is greater than preemptee's priority func Preemptable(preemptor, preemptee *v1.Pod) bool { if IsCriticalPod(preemptor) && !IsCriticalPod(preemptee) { return true } if (preemptor != nil && preemptor.Spec.Priority != nil) && (preemptee != nil && preemptee.Spec.Priority != nil) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 07 22:26:12 UTC 2023 - 6.4K bytes - Viewed (0) -
pkg/kubelet/types/pod_update_test.go
tests := []struct { name string preemptor *v1.Pod preemptee *v1.Pod expected bool }{ { name: "a critical preemptor pod preempts a non critical pod", preemptor: getTestPod(configSourceAnnotation(FileSource), nil, ""), preemptee: getTestPod(nil, nil, ""), expected: true, }, { name: "a preemptor pod with higher priority preempts a critical pod",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 21 08:20:50 UTC 2023 - 10.4K bytes - Viewed (0) -
src/runtime/preempt.go
if preemptMSupported && debug.asyncpreemptoff == 0 && needAsync { // Rate limit preemptM calls. This is // particularly important on Windows // where preemptM is actually // synchronous and the spin loop here // can lead to live-lock. now := nanotime() if now >= nextPreemptM { nextPreemptM = now + yieldDelay/2 preemptM(asyncM) } } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 15:41:45 UTC 2024 - 15.1K bytes - Viewed (0) -
pkg/scheduler/framework/preemption/preemption.go
} fh.EventRecorder().Eventf(victim, pod, v1.EventTypeNormal, "Preempted", "Preempting", "Preempted by pod %v on node %v", pod.UID, c.Name()) } fh.Parallelizer().Until(ctx, len(c.Victims().Pods), preemptPod, ev.PluginName) if err := errCh.ReceiveError(); err != nil { return framework.AsStatus(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 25.1K bytes - Viewed (0) -
pkg/kubelet/preemption/preemption.go
return s + "]" } // sortPodsByQOS returns lists containing besteffort, burstable, and guaranteed pods that // can be preempted by preemptor pod. func sortPodsByQOS(preemptor *v1.Pod, pods []*v1.Pod) (bestEffort, burstable, guaranteed []*v1.Pod) { for _, pod := range pods { if kubetypes.Preemptable(preemptor, pod) { switch v1qos.GetPodQOS(pod) { case v1.PodQOSBestEffort: bestEffort = append(bestEffort, pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 02 16:53:19 UTC 2023 - 11.5K bytes - Viewed (0) -
src/runtime/testdata/testprog/preempt.go
debug.SetGCPercent(-1) // Out of an abundance of caution, also make sure that there are // no GCs actively in progress. The sweep phase of a GC cycle // for instance tries to preempt Ps at the very beginning. runtime.GC() // Start a goroutine with no sync safe-points. var ready, ready2 uint32 go func() { for { atomic.StoreUint32(&ready, 1) dummy() dummy() } }()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Dec 07 17:46:04 UTC 2021 - 1.6K bytes - Viewed (0) -
pkg/kubelet/preemption/preemption_test.go
runs := []testRun{ { testName: "critical pods cannot be preempted", inputPods: []*v1.Pod{allPods[clusterCritical]}, insufficientResources: getAdmissionRequirementList(0, 0, 1), expectErr: true, expectedOutput: nil, }, { testName: "best effort pods are not preempted when attempting to free resources",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jul 24 10:04:08 UTC 2022 - 19.2K bytes - Viewed (0) -
src/runtime/proc_test.go
// If runtime triggers a forced GC during this test then it will deadlock, // since the goroutines can't be stopped/preempted. // Disable GC for this test (see issue #10958). defer debug.SetGCPercent(debug.SetGCPercent(-1)) // SetGCPercent waits until the mark phase is over, but the runtime // also preempts at the start of the sweep phase, so make sure that's // done too. See #45867. runtime.GC() for try := 0; try < N; try++ {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 14 00:03:57 UTC 2023 - 25.8K bytes - Viewed (0) -
src/runtime/os_windows.go
unlock(&mp.threadLock) atomic.Store(&mp.preemptExtLock, 0) mp.preemptGen.Add(1) return } var thread uintptr if stdcall7(_DuplicateHandle, currentProcess, mp.thread, currentProcess, uintptr(unsafe.Pointer(&thread)), 0, 0, _DUPLICATE_SAME_ACCESS) == 0 { print("runtime.preemptM: duplicatehandle failed; errno=", getlasterror(), "\n") throw("runtime.preemptM: duplicatehandle failed") } unlock(&mp.threadLock)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 22:55:25 UTC 2024 - 41.5K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/defaultpreemption/default_preemption.go
// There're several reasons: // 1. The pod has a preemptionPolicy of Never. // 2. The pod has already preempted other pods and the victims are in their graceful termination period. // Currently we check the node that is nominated for this pod, and as long as there are // terminating pods on this node, we don't attempt to preempt more pods.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Nov 25 19:36:04 UTC 2023 - 12.7K bytes - Viewed (0)