- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for netpollAdjustWaiters (0.2 sec)
-
src/runtime/netpoll_stub.go
osyield() } return gList{}, 0 } func netpollinited() bool { return netpollInited.Load() != 0 } func netpollAnyWaiters() bool { return false } func netpollAdjustWaiters(delta int32) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 1.5K bytes - Viewed (0) -
src/runtime/netpoll.go
} // netpollAnyWaiters reports whether any goroutines are waiting for I/O. func netpollAnyWaiters() bool { return netpollWaiters.Load() > 0 } // netpollAdjustWaiters adds delta to netpollWaiters. func netpollAdjustWaiters(delta int32) { if delta != 0 { netpollWaiters.Add(delta) } } func (c *pollCache) alloc() *pollDesc { lock(&c.lock) if c.first == nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 19:57:43 UTC 2024 - 20.7K bytes - Viewed (0) -
src/runtime/proc.go
} lock(&sched.lock) pp, _ := pidleget(now) unlock(&sched.lock) if pp == nil { injectglist(&list) netpollAdjustWaiters(delta) } else { acquirep(pp) if !list.empty() { gp := list.pop() injectglist(&list) netpollAdjustWaiters(delta) trace := traceAcquire() casgstatus(gp, _Gwaiting, _Grunnable) if trace.ok() { trace.GoUnpark(gp, 0)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 207.5K bytes - Viewed (0)