1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
|
/*
* 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"
#include "rubyio.h"
#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;
};
#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 */
|
