- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for preemption (0.13 sec)
-
src/sync/atomic/value.go
} vp := (*efaceWords)(unsafe.Pointer(v)) vlp := (*efaceWords)(unsafe.Pointer(&val)) for { typ := LoadPointer(&vp.typ) if typ == nil { // Attempt to start first store. // Disable preemption so that other goroutines can use // active spin wait to wait for completion. runtime_procPin() if !CompareAndSwapPointer(&vp.typ, nil, unsafe.Pointer(&firstStoreInProgress)) { runtime_procUnpin() continue
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 20:48:55 UTC 2024 - 5.9K bytes - Viewed (0) -
src/runtime/debug.go
func debug_modinfo() string { return modinfo } // mayMoreStackPreempt is a maymorestack hook that forces a preemption // at every possible cooperative preemption point. // // This is valuable to apply to the runtime, which can be sensitive to // preemption points. To apply this to all preemption points in the // runtime and runtime-like code, use the following in bash or zsh: //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat May 11 20:38:24 UTC 2024 - 4.2K bytes - Viewed (0) -
src/internal/abi/symtab.go
) // Special values for the PCDATA_UnsafePoint table. const ( UnsafePointSafe = -1 // Safe for async preemption UnsafePointUnsafe = -2 // Unsafe for async preemption // UnsafePointRestart1(2) apply on a sequence of instructions, within // which if an async preemption happens, we should back off the PC // to the start of the sequence when resuming.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 16 14:25:22 UTC 2024 - 3.6K bytes - Viewed (0) -
pkg/scheduler/framework/extender.go
// The possible changes made by extender may include: // 1. Subset of given candidate nodes after preemption phase of extender. // 2. A different set of victim pod for every given candidate node after preemption phase of extender. ProcessPreemption( pod *v1.Pod, nodeNameToVictims map[string]*extenderv1.Victims, nodeInfos NodeInfoLister,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 3.3K bytes - Viewed (0) -
src/runtime/mwbbuf.go
// p := buf.get2() // p[0], p[1] = old, new // ... actual memory write ... // // The caller must ensure there are no preemption points during the // above sequence. There must be no preemption points while buf is in // use because it is a per-P resource. There must be no preemption // points between the buffer put and the write to memory because this // could allow a GC phase change, which could result in missed write
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 8.1K bytes - Viewed (0) -
src/internal/runtime/exithook/hooks.go
// Package exithook provides limited support for on-exit cleanup. // // CAREFUL! The expectation is that Add should only be called // from a safe context (e.g. not an error/panic path or signal // handler, preemption enabled, allocation allowed, write barriers // allowed, etc), and that the exit function F will be invoked under // similar circumstances. That is the say, we are expecting that F
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 16:41:13 UTC 2024 - 2.2K bytes - Viewed (0) -
manifests/charts/gateway/values.yaml
# Configure this to a higher priority class in order to make sure your Istio gateway pods # will not be killed because of low priority class. # Refer to https://kubernetes.io/docs/concepts/configuration/pod-priority-preemption/#priorityclass # for more detail.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 07 16:51:35 UTC 2024 - 4.4K bytes - Viewed (0) -
src/sync/pool.go
} } // Mark the victim cache as empty for future gets don't bother // with it. atomic.StoreUintptr(&p.victimSize, 0) return nil } // pin pins the current goroutine to P, disables preemption and // returns poolLocal pool for the P and the P's id. // Caller must call runtime_procUnpin() when done with the pool. func (p *Pool) pin() (*poolLocal, int) { // Check whether p is nil to get a panic.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 9.4K bytes - Viewed (1) -
src/runtime/lock_futex.go
} gp := getg() gp.m.mLockProfile.recordUnlock(l) gp.m.locks-- if gp.m.locks < 0 { throw("runtimeĀ·unlock: lock count") } if gp.m.locks == 0 && gp.preempt { // restore the preemption request in case we've cleared it in newstack gp.stackguard0 = stackPreempt } } // One-time notifications. func noteclear(n *note) { n.key = 0 } func notewakeup(n *note) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:34 UTC 2024 - 5.4K bytes - Viewed (0) -
src/runtime/testdata/testprog/lockosthread.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 20:00:09 UTC 2024 - 6.6K bytes - Viewed (0)