- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for netpollclose (0.4 sec)
-
src/runtime/netpoll_fake.go
package runtime func netpollinit() { } func netpollIsPollDescriptor(fd uintptr) bool { return false } func netpollopen(fd uintptr, pd *pollDesc) int32 { return 0 } func netpollclose(fd uintptr) int32 { return 0 } func netpollarm(pd *pollDesc, mode int) { } func netpollBreak() { } func netpoll(delay int64) (gList, int32) { return gList{}, 0
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jul 20 15:45:57 UTC 2023 - 664 bytes - Viewed (0) -
src/runtime/netpoll_epoll.go
tp := taggedPointerPack(unsafe.Pointer(pd), pd.fdseq.Load()) *(*taggedPointer)(unsafe.Pointer(&ev.Data)) = tp return syscall.EpollCtl(epfd, syscall.EPOLL_CTL_ADD, int32(fd), &ev) } func netpollclose(fd uintptr) uintptr { var ev syscall.EpollEvent return syscall.EpollCtl(epfd, syscall.EPOLL_CTL_DEL, int32(fd), &ev) } func netpollarm(pd *pollDesc, mode int) { throw("runtime: unused") }
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
// as mtxset protects us from stale pollDescs. pd.user = uint32(len(pfds)) pfds = append(pfds, pollfd{fd: int32(fd)}) pds = append(pds, pd) unlock(&mtxset) return 0 } func netpollclose(fd uintptr) int32 { lock(&mtxpoll) netpollwakeup() lock(&mtxset) unlock(&mtxpoll) for i := 0; i < len(pfds); i++ { if pfds[i].fd == int32(fd) { pfds[i] = pfds[len(pfds)-1]
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
ev[0].udata = (*byte)(unsafe.Pointer(uintptr(tp))) } ev[1] = ev[0] ev[1].filter = _EVFILT_WRITE n := kevent(kq, &ev[0], 2, nil, 0, nil) if n < 0 { return -n } return 0 } func netpollclose(fd uintptr) int32 { // Don't need to unregister because calling close() // on fd will remove any kevents that reference the descriptor. return 0 } func netpollarm(pd *pollDesc, mode int) {
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
ridx = to } else if widx == from { widx = to } pd.user = uint32(ridx)<<16 | uint32(widx) if to != disarmed { subs[to], subs[from] = subs[from], subs[to] } } func netpollclose(fd uintptr) int32 { lock(&mtx) for i := 0; i < len(pds); i++ { if pds[i].fd == fd { netpolldisarm(pds[i], 'r'+'w') pds[i] = pds[len(pds)-1] pds = pds[:len(pds)-1] break } }
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
key := packNetpollKey(netpollSourceReady, pd) if stdcall4(_CreateIoCompletionPort, fd, iocphandle, key, 0) == 0 { return int32(getlasterror()) } return 0 } func netpollclose(fd uintptr) int32 { // nothing to do return 0 } func netpollarm(pd *pollDesc, mode int) { throw("runtime: unused") } func netpollBreak() {
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.go
// // func netpollopen(fd uintptr, pd *pollDesc) int32 // Arm edge-triggered notifications for fd. The pd argument is to pass // back to netpollready when fd is ready. Return an errno value. // // func netpollclose(fd uintptr) int32 // Disable notifications for fd. Return an errno value. // // func netpoll(delta int64) (gList, int32) // Poll the network. If delta < 0, block indefinitely. If delta == 0,
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_solaris.go
if goarch.PtrSize != 8 { throw("runtime: netpollopen: unsupported pointer size") } r := port_associate(portfd, _PORT_SOURCE_FD, fd, 0, uintptr(tp)) unlock(&pd.lock) return r } func netpollclose(fd uintptr) int32 { return port_dissociate(portfd, _PORT_SOURCE_FD, fd) } // Updates the association with a new set of interested events. After // this call, port_getn will return one and only one event for that
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 11.2K bytes - Viewed (0)