blob: 799ca4d6d53d65f06aa96a6148fe1780b2eab8ac (
plain)
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
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
|
#ifndef IOLOOP_PRIVATE_H
#define IOLOOP_PRIVATE_H
#include "priorityq.h"
#include "ioloop.h"
#include "array-decl.h"
#ifndef IOLOOP_INITIAL_FD_COUNT
# define IOLOOP_INITIAL_FD_COUNT 128
#endif
struct ioloop {
struct ioloop *prev;
struct ioloop_context *cur_ctx;
struct io_file *io_files;
struct io_file *next_io_file;
struct priorityq *timeouts;
ARRAY(struct timeout *) timeouts_new;
struct io_wait_timer *wait_timers;
struct ioloop_handler_context *handler_context;
struct ioloop_notify_handler_context *notify_handler_context;
unsigned int max_fd_count;
io_loop_time_moved_callback_t *time_moved_callback;
struct timeval next_max_time;
uint64_t ioloop_wait_usecs;
struct timeval wait_started;
unsigned int io_pending_count;
bool running:1;
bool iolooping:1;
bool stop_after_run_loop:1;
};
struct io {
enum io_condition condition;
const char *source_filename;
unsigned int source_linenum;
/* trigger I/O callback even if OS doesn't think there is input
pending */
bool pending;
/* This IO event shouldn't be the only thing being waited on, because
it would just result in infinite wait. */
bool never_wait_alone;
io_callback_t *callback;
void *context;
struct ioloop *ioloop;
struct ioloop_context *ctx;
};
struct io_file {
struct io io;
/* use a doubly linked list so that io_remove() is quick */
struct io_file *prev, *next;
int refcount;
int fd;
/* only for io_add_istream(), a bit kludgy to be here.. */
struct istream *istream;
};
struct timeout {
struct priorityq_item item;
const char *source_filename;
unsigned int source_linenum;
unsigned int msecs;
struct timeval next_run;
timeout_callback_t *callback;
void *context;
struct ioloop *ioloop;
struct ioloop_context *ctx;
bool one_shot:1;
};
struct io_wait_timer {
struct io_wait_timer *prev, *next;
const char *source_filename;
unsigned int source_linenum;
struct ioloop *ioloop;
uint64_t usecs;
};
struct ioloop_context_callback {
io_callback_t *activate;
io_callback_t *deactivate;
void *context;
bool activated;
};
struct ioloop_context {
int refcount;
struct ioloop *ioloop;
ARRAY(struct ioloop_context_callback) callbacks;
ARRAY(struct event *) global_event_stack;
struct event *root_global_event;
};
int io_loop_run_get_wait_time(struct ioloop *ioloop, struct timeval *tv_r);
void io_loop_handle_timeouts(struct ioloop *ioloop);
void io_loop_call_io(struct io *io);
void io_loop_handler_run_internal(struct ioloop *ioloop);
/* I/O handler calls */
void io_loop_handle_add(struct io_file *io);
void io_loop_handle_remove(struct io_file *io, bool closed);
void io_loop_handler_init(struct ioloop *ioloop, unsigned int initial_fd_count);
void io_loop_handler_deinit(struct ioloop *ioloop);
void io_loop_notify_remove(struct io *io);
void io_loop_notify_handler_deinit(struct ioloop *ioloop);
struct event *io_loop_get_active_global_root(void);
#endif
|
