- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for netpollopen (0.57 sec)
-
src/runtime/netpoll_fake.go
//go:build js && wasm 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() { }
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_kqueue.go
) func netpollinit() { kq = kqueue() if kq < 0 { println("runtime: kqueue failed with", -kq) throw("runtime: netpollinit failed") } closeonexec(kq) addWakeupEvent(kq) } func netpollopen(fd uintptr, pd *pollDesc) int32 { // Arm both EVFILT_READ and EVFILT_WRITE in edge-triggered mode (EV_CLEAR) // for the whole fd lifetime. The notifications are automatically unregistered // when fd is closed.
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_epoll.go
throw("runtime: epollctl failed") } netpollEventFd = uintptr(efd) } func netpollIsPollDescriptor(fd uintptr) bool { return fd == uintptr(epfd) || fd == netpollEventFd } func netpollopen(fd uintptr, pd *pollDesc) uintptr { var ev syscall.EpollEvent ev.Events = syscall.EPOLLIN | syscall.EPOLLOUT | syscall.EPOLLRDHUP | syscall.EPOLLET tp := taggedPointerPack(unsafe.Pointer(pd), pd.fdseq.Load())
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
func netpollwakeup() { if pendingUpdates == 0 { pendingUpdates = 1 b := [1]byte{0} write(uintptr(wrwake), unsafe.Pointer(&b[0]), 1) } } func netpollopen(fd uintptr, pd *pollDesc) int32 { lock(&mtxpoll) netpollwakeup() lock(&mtxset) unlock(&mtxpoll) // We don't worry about pd.fdseq here, // as mtxset protects us from stale pollDescs.
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_solaris.go
} print("runtime: port_create failed (errno=", errno(), ")\n") throw("runtime: netpollinit failed") } func netpollIsPollDescriptor(fd uintptr) bool { return fd == uintptr(portfd) } func netpollopen(fd uintptr, pd *pollDesc) int32 { lock(&pd.lock) // We don't register for any specific type of events yet, that's // netpollarm's job. We merely ensure we call port_associate before
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 11.2K bytes - Viewed (0) -
src/runtime/netpoll_wasip1.go
*eventtype = eventtypeClock clock := timeout.u.subscriptionClock() clock.id = clockMonotonic clock.precision = 1e3 } func netpollIsPollDescriptor(fd uintptr) bool { return false } func netpollopen(fd uintptr, pd *pollDesc) int32 { lock(&mtx) // We don't worry about pd.fdseq here, // as mtx protects us from stale pollDescs. pds = append(pds, pd)
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
throw("runtime: netpollinit failed") } } func netpollIsPollDescriptor(fd uintptr) bool { return fd == iocphandle } func netpollopen(fd uintptr, pd *pollDesc) int32 { key := packNetpollKey(netpollSourceReady, pd) if stdcall4(_CreateIoCompletionPort, fd, iocphandle, key, 0) == 0 { return int32(getlasterror()) } return 0 }
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
// A particular implementation (epoll/kqueue/port/AIX/Windows) // must define the following functions: // // func netpollinit() // Initialize the poller. Only called once. // // 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
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 19:57:43 UTC 2024 - 20.7K bytes - Viewed (0)