- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 132 for preemptee (0.15 sec)
-
src/cmd/internal/obj/loong64/obj.go
p.From.Offset = 3 * int64(c.ctxt.Arch.PtrSize) // G.stackguard1 } p.To.Type = obj.TYPE_REG p.To.Reg = REG_R20 // Mark the stack bound check and morestack call async nonpreemptible. // If we get preempted here, when resumed the preemption request is // cleared, but we'll still call morestack, which will double the stack // unnecessarily. See issue #35470. p = c.ctxt.StartUnsafePoint(p, c.newprog) var q *obj.Prog
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 19:22:18 UTC 2023 - 19.7K bytes - Viewed (0) -
src/runtime/mkpreempt.go
if !ok { log.Fatalf("unknown arch %s", arch) } header(arch) gen() } return } for arch, gen := range arches { f, err := os.Create(fmt.Sprintf("preempt_%s.s", arch)) if err != nil { log.Fatal(err) } out = f header(arch) gen() if err := f.Close(); err != nil { log.Fatal(err) } } } func header(arch string) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Nov 20 17:19:36 UTC 2023 - 15.3K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework.go
// for nominated pod on the given node. // This function is called from two different places: Schedule and Preempt. // When it is called from Schedule, we want to test whether the pod is // schedulable on the node with all the existing pods on the node plus higher // and equal priority pods nominated to run on the node. // When it is called from Preempt, we should remove the victims of preemption // and add the nominated pods. Removal of the victims is done by
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/extern.go
non-preemptible for long periods, which may delay GC and goroutine scheduling. This is useful for debugging GC issues because it also disables the conservative stack scanning used for asynchronously preempted goroutines. The [net] and [net/http] packages also refer to debugging variables in GODEBUG. See the documentation for those packages for details.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:52:17 UTC 2024 - 18.9K bytes - Viewed (0) -
src/runtime/runtime1.go
//go:nosplit func acquirem() *m { gp := getg() gp.m.locks++ return gp.m } //go:nosplit func releasem(mp *m) { gp := getg() mp.locks-- if mp.locks == 0 && gp.preempt { // restore the preemption request in case we've cleared it in newstack gp.stackguard0 = stackPreempt } } // reflect_typelinks is meant for package reflect,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:52:17 UTC 2024 - 19.3K bytes - Viewed (0) -
src/cmd/internal/obj/arm/obj5.go
p.From.Offset = 3 * int64(c.ctxt.Arch.PtrSize) // G.stackguard1 } p.To.Type = obj.TYPE_REG p.To.Reg = REG_R1 // Mark the stack bound check and morestack call async nonpreemptible. // If we get preempted here, when resumed the preemption request is // cleared, but we'll still call morestack, which will double the stack // unnecessarily. See issue #35470. p = c.ctxt.StartUnsafePoint(p, c.newprog)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Nov 20 17:19:36 UTC 2023 - 21.4K bytes - Viewed (0) -
src/cmd/internal/obj/s390x/objz.go
p.From.Offset = 3 * int64(c.ctxt.Arch.PtrSize) // G.stackguard1 } p.To.Type = obj.TYPE_REG p.To.Reg = REG_R3 // Mark the stack bound check and morestack call async nonpreemptible. // If we get preempted here, when resumed the preemption request is // cleared, but we'll still call morestack, which will double the stack // unnecessarily. See issue #35470. p = c.ctxt.StartUnsafePoint(p, c.newprog)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 21 19:28:53 UTC 2023 - 21K bytes - Viewed (0) -
src/runtime/trace.go
// events based on the G's status. We need the global trace buffer flush // coming up to make sure we're not racing with the G. // // It should be very unlikely that we try to preempt a running G here. // The only situation that we might is that we're racing with a G // that's running for the first time in this generation. Therefore, // this should be relatively fast. s := suspendG(gp)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:17:41 UTC 2024 - 37.1K bytes - Viewed (0) -
src/runtime/chan_test.go
// the GC is going to want to shrink us // when it scans us. Make sure not to // do any function calls otherwise // in order to avoid us shrinking ourselves // when we're preempted. stackGrowthRecursive(20) } done <- struct{}{} } recv := func(c <-chan int, done chan struct{}) { for i := 0; i < n; i++ { // Sleep here so that the sender always // fully blocks.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Oct 31 20:47:35 UTC 2023 - 23.4K bytes - Viewed (0) -
src/runtime/os_linux.go
// // We achieve these through different mechanisms: // // 1. Addition of new Ms to allm in allocm happens before clone of its // OS thread later in newm. // 2. newm does acquirem to avoid being preempted, ensuring that new Ms // created in allocm will eventually reach OS thread clone later in // newm. // 3. We take allocmLock for write here to prevent allocation of new Ms
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 25.9K bytes - Viewed (0)