Searched defs:ioloop (Results 1 - 25 of 77) sorted by relevance

1234

/dovecot/src/anvil/
H A Dtest-penalty.c4 #include "ioloop.h"
11 struct ioloop *ioloop; local
17 ioloop = io_loop_create();
53 io_loop_destroy(&ioloop);
/dovecot/src/lib/
H A Dtest-log-throttle.c4 #include "ioloop.h"
10 struct ioloop *ioloop)
13 io_loop_stop(ioloop);
24 struct ioloop *ioloop; local
29 ioloop = io_loop_create();
30 throttle = log_throttle_init(&set, test_log_throttle_callback, ioloop);
38 io_loop_run(ioloop);
47 io_loop_run(ioloop);
9 test_log_throttle_callback(unsigned int new_events_count, struct ioloop *ioloop) argument
[all...]
H A Diostream-private.h17 struct ioloop *ioloop; member in struct:iostream_private
48 struct ioloop *ioloop);
49 struct ioloop *io_stream_get_ioloop(struct iostream_private *stream);
H A Dtest-iostream-proxy.c7 #include "ioloop.h"
42 struct ioloop *ioloop = io_loop_create(); local
74 io_loop_run(ioloop);
86 io_loop_run(ioloop);
94 io_loop_destroy(&ioloop);
H A Dtest-lib-signals.c5 #include "ioloop.h"
45 struct ioloop *ioloop; local
55 ioloop = io_loop_create();
58 io_loop_run(ioloop);
62 io_loop_destroy(&ioloop);
71 test_begin("lib-signals delayed - init ioloop first");
75 ioloop = io_loop_create();
83 io_loop_run(ioloop);
90 io_loop_destroy(&ioloop);
[all...]
H A Dioloop-kqueue.c2 * BSD kqueue() based ioloop handler.
12 #include "ioloop-private.h"
37 void io_loop_handler_init(struct ioloop *ioloop, unsigned int initial_fd_count) argument
41 ioloop->handler_context = ctx = i_new(struct ioloop_handler_context, 1);
50 void io_loop_handler_deinit(struct ioloop *ioloop) argument
52 if (close(ioloop->handler_context->kq) < 0)
54 array_free(&ioloop->handler_context->events);
55 i_free(ioloop
110 io_loop_handler_run_internal(struct ioloop *ioloop) argument
[all...]
H A Dioloop-select.c4 #include "ioloop-private.h"
20 static void update_highest_fd(struct ioloop *ioloop) argument
22 struct ioloop_handler_context *ctx = ioloop->handler_context;
29 for (io = ioloop->io_files; io != NULL; io = io->next) {
40 void io_loop_handler_init(struct ioloop *ioloop, argument
45 ioloop->handler_context = ctx = i_new(struct ioloop_handler_context, 1);
52 void io_loop_handler_deinit(struct ioloop *ioloop) argument
106 io_loop_handler_run_internal(struct ioloop *ioloop) argument
[all...]
H A Distream-timeout.c4 #include "ioloop.h"
31 struct ioloop *ioloop)
36 tstream->to = io_loop_move_timeout_to(ioloop, &tstream->to);
79 /* make sure we get called again on the next ioloop run. this updates
82 outside the ioloop it's not counted) */
30 i_stream_timeout_switch_ioloop_to(struct istream_private *stream, struct ioloop *ioloop) argument
H A Dtest-ostream-multiplex.c4 #include "ioloop.h"
105 struct ioloop *ioloop = io_loop_create(); local
106 io_loop_set_current(ioloop);
136 io_loop_destroy(&ioloop);
H A Dioloop-epoll.c5 #include "ioloop-private.h"
6 #include "ioloop-iolist.h"
21 void io_loop_handler_init(struct ioloop *ioloop, unsigned int initial_fd_count) argument
25 ioloop->handler_context = ctx = i_new(struct ioloop_handler_context, 1);
42 void io_loop_handler_deinit(struct ioloop *ioloop) argument
44 struct ioloop_handler_context *ctx = ioloop->handler_context;
54 array_free(&ioloop->handler_context->fd_index);
55 array_free(&ioloop
163 io_loop_handler_run_internal(struct ioloop *ioloop) argument
[all...]
H A Dioloop-notify-inotify.c8 #include "ioloop-private.h"
9 #include "ioloop-notify-fd.h"
33 static bool inotify_input_more(struct ioloop *ioloop) argument
36 ioloop->notify_handler_context;
80 static void inotify_input(struct ioloop *ioloop) argument
82 while (inotify_input_more(ioloop)) ;
136 _io->ioloop->notify_handler_context;
171 struct ioloop *ioloo local
191 io_loop_notify_handler_deinit(struct ioloop *ioloop) argument
211 io_loop_extract_notify_fd(struct ioloop *ioloop) argument
[all...]
H A Dioloop-notify-kqueue.c2 * BSD kqueue() based ioloop notify handler.
12 #include "ioloop-private.h"
104 void io_loop_notify_handler_deinit(struct ioloop *ioloop) argument
107 ioloop->notify_handler_context;
157 io->io.ioloop = current_ioloop;
176 io->io.ioloop->notify_handler_context);
186 _io->ioloop->notify_handler_context;
201 int io_loop_extract_notify_fd(struct ioloop *ioloop) argument
[all...]
H A Dioloop-poll.c6 #include "ioloop-private.h"
21 void io_loop_handler_init(struct ioloop *ioloop, unsigned int initial_fd_count) argument
25 ioloop->handler_context = ctx = i_new(struct ioloop_handler_context, 1);
34 void io_loop_handler_deinit(struct ioloop *ioloop) argument
36 i_free(ioloop->handler_context->fds);
37 i_free(ioloop->handler_context->fd_index);
38 i_free(ioloop->handler_context);
47 struct ioloop_handler_context *ctx = io->io.ioloop
144 io_loop_handler_run_internal(struct ioloop *ioloop) argument
[all...]
H A Diostream.c26 stream->ioloop = current_ioloop;
146 struct ioloop *ioloop)
148 stream->ioloop = ioloop;
151 struct ioloop *io_stream_get_ioloop(struct iostream_private *stream)
153 return (stream->ioloop == NULL ? current_ioloop : stream->ioloop);
145 io_stream_switch_ioloop_to(struct iostream_private *stream, struct ioloop *ioloop) argument
H A Dtest-ioloop.c6 #include "ioloop.h"
46 test_begin("ioloop fd");
61 struct ioloop *ioloop = io_loop_create(); local
76 io_loop_run(ioloop);
86 io_loop_destroy(&ioloop);
95 struct ioloop *ioloop, *ioloop2; local
99 test_begin("ioloop timeout");
101 ioloop
147 struct ioloop *ioloop; local
187 struct ioloop *ioloop = io_loop_create(); local
[all...]
H A Dtest-iostream-pump.c8 #include "ioloop.h"
72 struct ioloop *ioloop = io_loop_create(); local
73 io_loop_set_current(ioloop);
115 io_loop_destroy(&ioloop);
H A Dtest-multiplex.c4 #include "ioloop.h"
121 struct ioloop *ioloop = io_loop_create(); local
122 io_loop_set_current(ioloop);
154 io_loop_destroy(&ioloop);
/dovecot/src/util/
H A Dmaildirlock.c5 #include "ioloop.h"
19 static struct ioloop *ioloop; variable in typeref:struct:ioloop
23 io_loop_stop(ioloop);
64 ioloop = io_loop_create();
98 io_loop_run(ioloop);
103 io_loop_destroy(&ioloop);
/dovecot/src/lib-dns/
H A Ddns-lookup.h15 /* ioloop to run the lookup on (defaults to current_ioloop) */
16 struct ioloop *ioloop; member in struct:dns_lookup_settings
/dovecot/src/lib-program-client/
H A Dtest-program-client-local.c107 struct ioloop *prev_ioloop = current_ioloop;
108 struct ioloop *ioloop = io_loop_create(); local
127 io_loop_run(ioloop);
137 io_loop_set_current(ioloop);
138 io_loop_destroy(&ioloop);
238 struct ioloop *ioloop = io_loop_create(); local
242 io_loop_destroy(&ioloop);
/dovecot/src/lib-storage/
H A Dmailbox-watch.c4 #include "ioloop.h"
111 struct ioloop *ioloop; local
118 /* add all the notify IOs to a new ioloop. */
119 ioloop = io_loop_create();
144 ret = io_loop_extract_notify_fd(ioloop);
152 io_loop_destroy(&ioloop);
/dovecot/src/director/
H A Dtest-user-directory.c4 #include "ioloop.h"
105 struct ioloop *ioloop = io_loop_create(); local
107 io_loop_destroy(&ioloop);
/dovecot/src/lib-dict/
H A Dtest-dict-client.c4 #include "ioloop.h"
36 struct ioloop *ioloop; local
42 ioloop = io_loop_create();
102 io_loop_destroy(&ioloop);
/dovecot/src/lib-ssl-iostream/
H A Dostream-openssl.c169 struct ioloop *ioloop)
173 o_stream_switch_ioloop_to(sstream->ssl_io->plain_output, ioloop);
168 o_stream_ssl_switch_ioloop_to(struct ostream_private *stream, struct ioloop *ioloop) argument
/dovecot/src/plugins/fts/
H A Dfts-parser-tika.c4 #include "ioloop.h"
27 struct ioloop *ioloop; member in struct:tika_fts_parser
175 struct ioloop *prev_ioloop = current_ioloop;
202 /* continue returning data from Tika. we'll create a new ioloop just
208 if (parser->ioloop == NULL) {
209 parser->ioloop = io_loop_create();
213 io_loop_set_current(parser->ioloop);
217 /* switch back to original ioloop. */
250 timeout to ioloop unnecessaril
[all...]

Completed in 126 milliseconds

1234