/* * Copyright (c) 2011 Tony Arcieri. Distributed under the MIT License. See * LICENSE.txt for further details. */ #ifndef NIO4R_H #define NIO4R_H #include "ruby.h" #if HAVE_RUBY_IO_H # include "ruby/io.h" #else # include "rubyio.h" #endif #include "libev.h" struct NIO_Selector { struct ev_loop *ev_loop; struct ev_timer timer; /* for timeouts */ struct ev_io wakeup; int wakeup_reader, wakeup_writer; int closed, selecting; int ready_count; VALUE ready_array; }; struct NIO_callback_data { VALUE *monitor; struct NIO_Selector *selector; }; struct NIO_Monitor { VALUE self; int interests, revents; struct ev_io ev_io; struct NIO_Selector *selector; }; struct NIO_ByteBuffer { int size, offset, limit, position, mark; char *buffer; VALUE self; }; #ifdef GetReadFile # define FPTR_TO_FD(fptr) (fileno(GetReadFile(fptr))) #else #if !HAVE_RB_IO_T || (RUBY_VERSION_MAJOR == 1 && RUBY_VERSION_MINOR == 8) # define FPTR_TO_FD(fptr) fileno(fptr->f) #else # define FPTR_TO_FD(fptr) fptr->fd #endif /* !HAVE_RB_IO_T */ #endif /* GetReadFile */ /* Thunk between libev callbacks in NIO::Monitors and NIO::Selectors */ void NIO_Selector_monitor_callback(struct ev_loop *ev_loop, struct ev_io *io, int revents); #endif /* NIO4R_H */