Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for netpollIsPollDescriptor (0.53 sec)

  1. src/runtime/netpoll_kqueue_event.go

    	}
    	return false
    }
    
    func drainWakeupEvent(kq int32) {
    	ev := keventt{
    		ident:  kqIdent,
    		filter: _EVFILT_USER,
    		flags:  _EV_DISABLE,
    	}
    	kevent(kq, &ev, 1, nil, 0, nil)
    }
    
    func netpollIsPollDescriptor(fd uintptr) bool {
    	return fd == uintptr(kq)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 24 17:15:46 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  2. src/runtime/netpoll_fake.go

    // Fake network poller for js/wasm.
    // Should never be used, because js/wasm network connections do not honor "SetNonblock".
    
    //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
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jul 20 15:45:57 UTC 2023
    - 664 bytes
    - Viewed (0)
  3. src/runtime/netpoll_kqueue_pipe.go

    	}
    	return false
    }
    
    func drainWakeupEvent(_ int32) {
    	var buf [16]byte
    	read(int32(netpollBreakRd), noescape(unsafe.Pointer(&buf[0])), int32(len(buf)))
    }
    
    func netpollIsPollDescriptor(fd uintptr) bool {
    	return fd == uintptr(kq) || fd == netpollBreakRd || fd == netpollBreakWr
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 12 21:17:22 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  4. src/runtime/netpoll_epoll.go

    	if errno != 0 {
    		println("runtime: epollctl failed with", errno)
    		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
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  5. src/runtime/netpoll_aix.go

    	pfds = make([]pollfd, 1, 128)
    
    	// Poll the read side of the pipe.
    	pfds[0].fd = rdwake
    	pfds[0].events = _POLLIN
    
    	pds = make([]*pollDesc, 1, 128)
    	pds[0] = nil
    }
    
    func netpollIsPollDescriptor(fd uintptr) bool {
    	return fd == uintptr(rdwake) || fd == uintptr(wrwake)
    }
    
    // netpollwakeup writes on wrwake to wakeup poll before any changes.
    func netpollwakeup() {
    	if pendingUpdates == 0 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  6. src/runtime/netpoll_wasip1.go

    	timeout := &subs[0]
    	eventtype := timeout.u.eventtype()
    	*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.
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Mar 27 18:23:49 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  7. src/runtime/netpoll_windows.go

    	if iocphandle == 0 {
    		println("runtime: CreateIoCompletionPort failed (errno=", getlasterror(), ")")
    		throw("runtime: netpollinit failed")
    	}
    }
    
    func netpollIsPollDescriptor(fd uintptr) bool {
    	return fd == iocphandle
    }
    
    func netpollopen(fd uintptr, pd *pollDesc) int32 {
    	key := packNetpollKey(netpollSourceReady, pd)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Mar 26 19:58:28 UTC 2024
    - 9.4K bytes
    - Viewed (0)
Back to top