Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 2,842 for kevent (0.26 sec)

  1. src/runtime/netpoll_kqueue_event.go

    			// to make a 100% commitment.
    			continue
    		}
    		println("runtime: kevent for EVFILT_USER failed with", -n)
    		throw("runtime: kevent failed")
    	}
    }
    
    func wakeNetpoll(kq int32) {
    	ev := keventt{
    		ident:  kqIdent,
    		filter: _EVFILT_USER,
    		flags:  _EV_ENABLE,
    		fflags: _NOTE_TRIGGER,
    	}
    	for {
    		n := kevent(kq, &ev, 1, nil, 0, nil)
    		if n == 0 {
    			break
    		}
    		if n == -_EINTR {
    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_kqueue_pipe.go

    		println("runtime: pipe failed with", -errno)
    		throw("runtime: pipe failed")
    	}
    	ev := keventt{
    		filter: _EVFILT_READ,
    		flags:  _EV_ADD,
    	}
    	*(*uintptr)(unsafe.Pointer(&ev.ident)) = uintptr(r)
    	n := kevent(kq, &ev, 1, nil, 0, nil)
    	if n < 0 {
    		println("runtime: kevent failed with", -n)
    		throw("runtime: kevent failed")
    	}
    	netpollBreakRd = uintptr(r)
    	netpollBreakWr = uintptr(w)
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 12 21:17:22 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  3. src/runtime/netpoll_kqueue.go

    		}
    		tp = &ts
    	}
    	var events [64]keventt
    retry:
    	n := kevent(kq, nil, 0, &events[0], int32(len(events)), tp)
    	if n < 0 {
    		// Ignore the ETIMEDOUT error for now, but try to dive deep and
    		// figure out what really happened with n == ETIMEOUT,
    		// see https://go.dev/issue/59679 for details.
    		if n != -_EINTR && n != -_ETIMEDOUT {
    			println("runtime: kevent on fd", kq, "failed with", -n)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 12 21:17:22 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  4. src/runtime/defs_dragonfly.go

    type Siginfo C.siginfo_t
    
    type Mcontext C.mcontext_t
    type Ucontext C.ucontext_t
    
    type Timespec C.struct_timespec
    type Timeval C.struct_timeval
    type Itimerval C.struct_itimerval
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 12 21:17:22 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  5. src/runtime/os_openbsd_syscall2.go

    package runtime
    
    import (
    	"internal/runtime/atomic"
    	"unsafe"
    )
    
    //go:noescape
    func sigaction(sig uint32, new, old *sigactiont)
    
    func kqueue() int32
    
    //go:noescape
    func kevent(kq int32, ch *keventt, nch int32, ev *keventt, nev int32, ts *timespec) int32
    
    func raiseproc(sig uint32)
    
    func getthrid() int32
    func thrkill(tid int32, sig int)
    
    // read calls the read system call.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  6. src/syscall/syscall_bsd.go

    		n = 0
    	}
    	return n, nil
    }
    
    //sys	kevent(kq int, change unsafe.Pointer, nchange int, event unsafe.Pointer, nevent int, timeout *Timespec) (n int, err error)
    
    func Kevent(kq int, changes, events []Kevent_t, timeout *Timespec) (n int, err error) {
    	var change, event unsafe.Pointer
    	if len(changes) > 0 {
    		change = unsafe.Pointer(&changes[0])
    	}
    	if len(events) > 0 {
    		event = unsafe.Pointer(&events[0])
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Nov 07 10:34:48 UTC 2023
    - 13.6K bytes
    - Viewed (0)
  7. src/runtime/sys_openbsd2.go

    //go:cgo_unsafe_args
    func kqueue() int32 {
    	return libcCall(unsafe.Pointer(abi.FuncPCABI0(kqueue_trampoline)), nil)
    }
    func kqueue_trampoline()
    
    //go:nosplit
    //go:cgo_unsafe_args
    func kevent(kq int32, ch *keventt, nch int32, ev *keventt, nev int32, ts *timespec) int32 {
    	ret := libcCall(unsafe.Pointer(abi.FuncPCABI0(kevent_trampoline)), unsafe.Pointer(&kq))
    	KeepAlive(ch)
    	KeepAlive(ev)
    	KeepAlive(ts)
    	return ret
    }
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  8. src/runtime/defs_netbsd.go

    type StackT C.stack_t
    
    type Timespec C.struct_timespec
    type Timeval C.struct_timeval
    type Itimerval C.struct_itimerval
    
    type McontextT C.mcontext_t
    type UcontextT C.ucontext_t
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 12 21:17:22 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  9. src/syscall/types_darwin.go

    )
    
    // Ptrace requests
    
    const (
    	PTRACE_TRACEME = C.PT_TRACE_ME
    	PTRACE_CONT    = C.PT_CONTINUE
    	PTRACE_KILL    = C.PT_KILL
    )
    
    // Events (kqueue, kevent)
    
    type Kevent_t C.struct_kevent
    
    // Select
    
    type FdSet C.fd_set
    
    // Routing and interface messages
    
    const (
    	SizeofIfMsghdr    = C.sizeof_struct_if_msghdr
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 28 18:17:57 UTC 2021
    - 5K bytes
    - Viewed (0)
  10. src/cmd/vendor/golang.org/x/sys/unix/syscall_bsd.go

    		n = 0
    	}
    	return n, nil
    }
    
    //sys	kevent(kq int, change unsafe.Pointer, nchange int, event unsafe.Pointer, nevent int, timeout *Timespec) (n int, err error)
    
    func Kevent(kq int, changes, events []Kevent_t, timeout *Timespec) (n int, err error) {
    	var change, event unsafe.Pointer
    	if len(changes) > 0 {
    		change = unsafe.Pointer(&changes[0])
    	}
    	if len(events) > 0 {
    		event = unsafe.Pointer(&events[0])
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Nov 29 21:28:33 UTC 2023
    - 15K bytes
    - Viewed (0)
Back to top