- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for netpollgoready (0.37 sec)
-
src/runtime/netpoll.go
pd.rt.stop() pd.rrun = false } if pd.wrun { pd.wt.stop() pd.wrun = false } unlock(&pd.lock) if rg != nil { netpollgoready(rg, 3) } if wg != nil { netpollgoready(wg, 3) } netpollAdjustWaiters(delta) } // netpollready is called by the platform-specific netpoll function. // It declares that the fd associated with pd is ready for I/O.
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/netpoll_epoll.go
tp := *(*taggedPointer)(unsafe.Pointer(&ev.Data)) pd := (*pollDesc)(tp.pointer()) tag := tp.tag() if pd.fdseq.Load() == tag { pd.setEventErr(ev.Events == syscall.EPOLLERR, tag) delta += netpollready(&toRun, pd, mode) } } } return toRun, delta
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 4.6K bytes - Viewed (0) -
src/runtime/netpoll_aix.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 5.1K bytes - Viewed (0) -
src/runtime/netpoll_kqueue.go
pd = (*pollDesc)(tp.pointer()) tag = tp.tag() if pd.fdseq.Load() != tag { continue } } pd.setEventErr(ev.flags == _EV_ERROR, tag) delta += netpollready(&toRun, pd, mode) } } return toRun, delta
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 12 21:17:22 UTC 2024 - 4.6K bytes - Viewed (0) -
src/runtime/netpoll_wasip1.go
mode += 'w' } if mode != 0 { pd := (*pollDesc)(unsafe.Pointer(uintptr(e.userdata))) netpolldisarm(pd, mode) pd.setEventErr(e.error != 0, 0) delta += netpollready(&toRun, pd, mode) } } unlock(&mtx) return toRun, delta
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 27 18:23:49 UTC 2024 - 6.1K bytes - Viewed (0) -
src/runtime/netpoll_windows.go
mode := op.mode if mode != 'r' && mode != 'w' { println("runtime: GetQueuedCompletionStatusEx returned net_op with invalid mode=", mode) throw("runtime: netpoll failed") } delta += netpollready(&toRun, op.pd, mode) case netpollSourceBreak: netpollWakeSig.Store(0) if delay == 0 { // Forward the notification to the blocked poller. netpollBreak() } case netpollSourceTimer:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 9.4K bytes - Viewed (0) -
src/runtime/netpoll_solaris.go
if mode != 0 { // TODO(mikio): Consider implementing event // scanning error reporting once we are sure // about the event port on SmartOS. // // See golang.org/x/issue/30840. delta += netpollready(&toRun, pd, mode) } } return toRun, delta
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 11.2K bytes - Viewed (0)