Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for netpollIsPollDescriptor (1.14 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)
  8. src/runtime/netpoll.go

    //     This will never return an empty list with a non-zero delta.
    //
    // func netpollBreak()
    //     Wake up the network poller, assumed to be blocked in netpoll.
    //
    // func netpollIsPollDescriptor(fd uintptr) bool
    //     Reports whether fd is a file descriptor used by the poller.
    
    // Error codes returned by runtime_pollReset and runtime_pollWait.
    // These must match the values in internal/poll/fd_poll_runtime.go.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 19:57:43 UTC 2024
    - 20.7K bytes
    - Viewed (0)
  9. src/runtime/netpoll_solaris.go

    	portfd = port_create()
    	if portfd >= 0 {
    		closeonexec(portfd)
    		return
    	}
    
    	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
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 11.2K bytes
    - Viewed (0)
Back to top