Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for nonblockingPipe (0.12 sec)

  1. src/runtime/netpoll_kqueue_pipe.go

    // via uname(3) and fall back to the pipe if the kernel version is older than 10.0.
    
    var netpollBreakRd, netpollBreakWr uintptr // for netpollBreak
    
    func addWakeupEvent(kq int32) {
    	r, w, errno := nonblockingPipe()
    	if errno != 0 {
    		println("runtime: pipe failed with", -errno)
    		throw("runtime: pipe failed")
    	}
    	ev := keventt{
    		filter: _EVFILT_READ,
    		flags:  _EV_ADD,
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 12 21:17:22 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  2. src/runtime/netpoll_aix.go

    	wrwake         int32
    	pendingUpdates int32
    
    	netpollWakeSig atomic.Uint32 // used to avoid duplicate calls of netpollBreak
    )
    
    func netpollinit() {
    	// Create the pipe we use to wakeup poll.
    	r, w, errno := nonblockingPipe()
    	if errno != 0 {
    		throw("netpollinit: failed to create pipe")
    	}
    	rdwake = r
    	wrwake = w
    
    	// Pre-allocate array of pollfd structures for poll.
    	pfds = make([]pollfd, 1, 128)
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 5.1K bytes
    - Viewed (0)
Back to top