- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for preemption (0.14 sec)
-
pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go
}, wantResult: framework.NewPostFilterResultWithNominatedNode(""), wantStatus: framework.NewStatus(framework.Unschedulable, "preemption: 0/1 nodes are available: 1 No preemption victims found for incoming pod."), }, { name: "preemption should respect filteredNodesStatuses", pod: st.MakePod().Name("p").UID("p").Namespace(v1.NamespaceDefault).Priority(highPriority).Obj(), pods: []*v1.Pod{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 82.8K bytes - Viewed (0) -
src/runtime/mgc.go
// Preemption must not occur here, or another G might see // p.gcMarkWorkerMode. // Disable preemption so we can use the gcw. If the // scheduler wants to preempt us, we'll stop draining, // dispose the gcw, and then preempt. node.m.set(acquirem()) pp := gp.m.p.ptr() // P can't change with preemption disabled. if gcBlackenEnabled == 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 16:25:21 UTC 2024 - 62K bytes - Viewed (0) -
src/runtime/mgcmark.go
// most this size. Since we can scan 1–2 MB/ms, 128 KB bounds // scan preemption at ~100 µs. // // This must be > _MaxSmallSize so that the object base is the // span base. maxObletBytes = 128 << 10 // drainCheckThreshold specifies how many units of work to do // between self-preemption checks in gcDrain. Assuming a scan // rate of 1 MB/ms, this is ~100 µs. Lower values have higher
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 18 21:25:11 UTC 2024 - 52.5K bytes - Viewed (0) -
src/runtime/malloc.go
// Objects can be zeroed late in a context where preemption can occur. // If the object contains pointers, its pointer data must be cleared // or otherwise indicate that the GC shouldn't scan it. // x will keep the memory alive. if delayedZeroing { // N.B. size == fullSize always in this case. memclrNoHeapPointersChunked(size, x) // This is a possible preemption point: see #47302
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 59.6K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework.go
s.SetPlugin(pl.Name()) if s.Code() == framework.UnschedulableAndUnresolvable { // In this case, the preemption shouldn't happen in this scheduling cycle. // So, no need to execute all PreFilter. return nil, s } if s.Code() == framework.Unschedulable { // In this case, the preemption should happen later in this scheduling cycle. // So we need to execute all PreFilter.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 60.9K bytes - Viewed (0) -
src/runtime/mheap.go
// then release mheap_.lock. allArenas []arenaIdx // sweepArenas is a snapshot of allArenas taken at the // beginning of the sweep cycle. This can be read safely by // simply blocking GC (by disabling preemption). sweepArenas []arenaIdx // markArenas is a snapshot of allArenas taken at the beginning // of the mark cycle. Because allArenas is append-only, neither
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:31:00 UTC 2024 - 78K bytes - Viewed (0) -
src/runtime/mprof.go
yield() continue } // While we have gp1.goroutineProfiled set to // goroutineProfileInProgress, gp1 may appear _Grunnable but will not // actually be able to run. Disable preemption for ourselves, to make // sure we finish profiling gp1 right away instead of leaving it stuck // in this limbo. mp := acquirem()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 53.3K bytes - Viewed (0) -
src/cmd/internal/obj/mips/asm0.go
} // isUnsafePoint returns whether p is an unsafe point. func (c *ctxt0) isUnsafePoint(p *obj.Prog) bool { // If p explicitly uses REGTMP, it's unsafe to preempt, because the // preemption sequence clobbers REGTMP. return p.From.Reg == REGTMP || p.To.Reg == REGTMP || p.Reg == REGTMP } // isRestartable returns whether p is a multi-instruction sequence that, // if preempted, can be restarted.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 16 17:46:09 UTC 2024 - 53.6K bytes - Viewed (0) -
src/cmd/internal/obj/loong64/asm.go
} // isUnsafePoint returns whether p is an unsafe point. func (c *ctxt0) isUnsafePoint(p *obj.Prog) bool { // If p explicitly uses REGTMP, it's unsafe to preempt, because the // preemption sequence clobbers REGTMP. return p.From.Reg == REGTMP || p.To.Reg == REGTMP || p.Reg == REGTMP } // isRestartable returns whether p is a multi-instruction sequence that, // if preempted, can be restarted.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 02:04:54 UTC 2024 - 61.8K bytes - Viewed (0) -
operator/pkg/apis/istio/v1alpha1/values_types.proto
google.protobuf.BoolValue operatorManageWebhooks = 41; // Specifies the k8s priorityClassName for the istio control plane components. // // See https://kubernetes.io/docs/concepts/configuration/pod-priority-preemption/#priorityclass string priorityClassName = 27 [deprecated = true]; // Specifies how proxies are configured within Istio. ProxyConfig proxy = 28;
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 01:55:05 UTC 2024 - 57.2K bytes - Viewed (0)