Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for netpollclose (0.4 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
Back to top