Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for netpollAdjustWaiters (0.2 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top