kqueue-mx

Vocabulary

io.backend.unix.multiplexers.kqueue

Definition

USING: io.backend.unix.multiplexers ;

IN: io.backend.unix.multiplexers.kqueue

TUPLE: kqueue-mx < mx events signals ;

Methods

USING: generic io.backend.unix.multiplexers
io.backend.unix.multiplexers.kqueue kernel unix.kqueue ;

M: kqueue-mx add-input-callback
    [ [ EVFILT_READ 17 make-kevent ] dip register-kevent ]
    [ M\ kqueue-mx add-input-callback (call-next-method) ] 2bi ;


USING: generic io.backend.unix.multiplexers
io.backend.unix.multiplexers.kqueue kernel unix.kqueue ;

M: kqueue-mx add-output-callback
    [ [ EVFILT_WRITE 17 make-kevent ] dip register-kevent ]
    [ M\ kqueue-mx add-output-callback (call-next-method) ] 2bi
    ;


USING: accessors assocs io.backend.unix.multiplexers
io.backend.unix.multiplexers.kqueue kernel unix.kqueue ;

M:: kqueue-mx add-signal-callback
    ( quot signal mx -- supported? )
    mx signals>> [ ] [ H{ } clone dup mx signals<< ] if*
    :> callbacks signal callbacks key?
    [ ]
    [ signal EVFILT_SIGNAL 33 make-kevent mx register-kevent ]
    if quot signal callbacks set-at t ;


USING: accessors destructors io.backend.unix.multiplexers.kqueue
unix ;

M: kqueue-mx dispose* fd>> close-file ;


USING: accessors assocs generic io.backend.unix.multiplexers
io.backend.unix.multiplexers.kqueue kernel unix.kqueue ;

M: kqueue-mx remove-input-callbacks
    2dup reads>> key? [
        [
            M\ kqueue-mx remove-input-callbacks
            (call-next-method)
        ] [
            [ EVFILT_READ EV_DELETE make-kevent ] dip
            register-kevent
        ] 2bi
    ] [ 2drop f ] if ;


USING: accessors assocs generic io.backend.unix.multiplexers
io.backend.unix.multiplexers.kqueue kernel unix.kqueue ;

M: kqueue-mx remove-output-callbacks
    2dup writes>> key? [
        [
            M\ kqueue-mx remove-output-callbacks
            (call-next-method)
        ] [
            [ EVFILT_WRITE EV_DELETE make-kevent ] dip
            register-kevent
        ] 2bi
    ] [ 2drop f ] if ;


USING: io.backend.unix.multiplexers
io.backend.unix.multiplexers.kqueue kernel unix.time ;

M: kqueue-mx wait-for-events
    swap dup [ make-timespec ] when dupd wait-kevent
    handle-kevents ;