Searched refs:io (Results 1 - 25 of 148) sorted by relevance

123456

/dovecot/src/lib/
H A Dioloop-notify-fd.c9 struct io *io_notify_fd_add(struct ioloop_notify_fd_context *ctx, int fd,
12 struct io_notify *io; local
14 io = i_new(struct io_notify, 1);
15 io->io.condition = IO_NOTIFY;
16 io->io.callback = callback;
17 io->io.context = context;
18 io
29 io_notify_fd_free(struct ioloop_notify_fd_context *ctx, struct io_notify *io) argument
45 struct io_notify *io; local
[all...]
H A Dioloop-kqueue.c58 void io_loop_handle_add(struct io_file *io) argument
60 struct ioloop_handler_context *ctx = io->io.ioloop->handler_context;
63 if ((io->io.condition & (IO_READ | IO_ERROR)) != 0) {
64 MY_EV_SET(&ev, io->fd, EVFILT_READ, EV_ADD, 0, 0, io);
66 i_panic("kevent(EV_ADD, READ, %d) failed: %m", io->fd);
68 if ((io->io
82 io_loop_handle_remove(struct io_file *io, bool closed) argument
117 struct io_file *io; local
[all...]
H A Dioloop-iolist.c11 bool ioloop_iolist_add(struct io_list *list, struct io_file *io) argument
15 if ((io->io.condition & IO_READ) != 0)
17 else if ((io->io.condition & IO_WRITE) != 0)
19 else if ((io->io.condition & IO_ERROR) != 0)
27 io->io.condition, io
42 ioloop_iolist_del(struct io_list *list, struct io_file *io) argument
[all...]
H A Dioloop-notify-fd.h7 struct io io; member in struct:io_notify
19 struct io *
23 struct io_notify *io);
H A Dioloop-notify-kqueue.c32 struct io io; member in struct:io_notify
40 struct io *event_io;
46 struct io_notify *io)
48 DLLIST_REMOVE(&ctx->notifies, io);
49 i_free(io);
54 struct io_notify *io; local
75 io = (void *)events[i].udata;
76 i_assert(io->refcount >= 1);
77 io
45 io_loop_notify_free(struct ioloop_notify_handler_context *ctx, struct io_notify *io) argument
110 struct io_notify *io = ctx->notifies; local
135 struct io_notify *io; local
187 struct io_notify *io = (struct io_notify *)_io; local
205 struct io_notify *io; local
[all...]
H A Dioloop-select.c23 struct io_file *io; local
29 for (io = ioloop->io_files; io != NULL; io = io->next) {
30 if (io->fd <= ctx->highest_fd)
33 ctx->highest_fd = io->fd;
57 void io_loop_handle_add(struct io_file *io) argument
59 struct ioloop_handler_context *ctx = io->io
78 io_loop_handle_remove(struct io_file *io, bool closed ATTR_UNUSED) argument
110 struct io_file *io; local
[all...]
H A Dioloop-iolist.h16 bool ioloop_iolist_add(struct io_list *list, struct io_file *io);
17 bool ioloop_iolist_del(struct io_list *list, struct io_file *io);
H A Dioloop-epoll.c66 struct io_file *io; local
69 io = list->ios[i];
71 if (io == NULL)
74 if ((io->io.condition & IO_READ) != 0)
76 if ((io->io.condition & IO_WRITE) != 0)
78 if ((io->io.condition & IO_ERROR) != 0)
85 void io_loop_handle_add(struct io_file *io) argument
126 io_loop_handle_remove(struct io_file *io, bool closed) argument
169 struct io_file *io; local
[all...]
H A Dioloop-notify-none.c14 void *context ATTR_UNUSED, struct io **io_r)
20 void io_loop_notify_remove(struct io *io ATTR_UNUSED)
H A Dioloop-poll.c45 void io_loop_handle_add(struct io_file *io) argument
47 struct ioloop_handler_context *ctx = io->io.ioloop->handler_context;
48 enum io_condition condition = io->io.condition;
50 int index, old_events, fd = io->fd;
97 void io_loop_handle_remove(struct io_file *io, bool closed ATTR_UNUSED) argument
99 struct ioloop_handler_context *ctx = io->io.ioloop->handler_context;
100 enum io_condition condition = io
149 struct io_file *io; local
[all...]
H A Dioloop.c42 struct io_file *io; local
47 io = i_new(struct io_file, 1);
48 io->io.condition = condition;
49 io->io.callback = callback;
50 io->io.context = context;
51 io->io
84 struct io_file *io; local
110 struct io_file *io; local
130 io_file_unlink(struct io_file *io) argument
148 struct io *io = *_io; local
190 io_remove(struct io **io) argument
198 io_remove_closed(struct io **io) argument
208 io_set_pending(struct io *io) argument
659 io_loop_call_io(struct io *io) argument
705 struct io_file *io; local
803 struct io_file *io = ioloop->io_files; local
1141 struct io_file *io; local
[all...]
H A Dioloop-private.h38 struct io { struct
54 struct io io; member in struct:io_file
107 void io_loop_call_io(struct io *io);
112 void io_loop_handle_add(struct io_file *io);
113 void io_loop_handle_remove(struct io_file *io, bool closed);
118 void io_loop_notify_remove(struct io *io);
H A Dioloop-notify-inotify.c26 struct io *event_io;
39 struct io_notify *io; local
65 io = io_notify_fd_find(&ctx->fd_ctx, event->wd);
66 if (io != NULL) {
70 io->fd = -1;
72 io_loop_call_io(&io->io);
89 io_callback_t *callback, void *context, struct io **io_r)
133 void io_loop_notify_remove(struct io *_io)
137 struct io_notify *io local
197 struct io_notify *io = ctx->fd_ctx.notifies; local
215 struct io_notify *io; local
[all...]
H A Diostream-pump.c17 struct io *io; member in struct:iostream_pump
44 io_remove(&pump->io);
48 io_remove(&pump->io);
53 io_remove(&pump->io);
57 io_remove(&pump->io);
94 if (pump->io == NULL) {
95 pump->io = io_add_istream(pump->input, iostream_pump_copy, pump);
96 io_set_pending(pump->io);
130 pump->io
[all...]
H A Dtest-ioloop.c63 struct io *io_left =
66 struct io *io_right =
139 struct io *io; member in struct:__anon46
148 struct io *io; local
158 tests[i].io = io_add(tests[i].fd[0], tests[i].condition, io_callback, NULL);
160 io = io_add(tests[i-1].fd[0], IO_WRITE, io_callback, NULL);
166 io_remove(&io);
168 io_remove(&tests[i].io);
188 struct io *io = io_add_istream(is, io_callback_pending_io, NULL); local
[all...]
/dovecot/src/auth/
H A Dauth-client-connection.h12 struct io *io; member in struct:auth_client_connection
H A Dauth-master-connection.h16 struct io *io; member in struct:auth_master_connection
/dovecot/src/lib-storage/
H A Dmailbox-watch.c19 struct io *io_notify;
62 struct io *io = NULL; local
66 (void)io_add_notify(path, notify_callback, box, &io);
72 file->io_notify = io;
113 struct io *io, *const *iop; local
114 ARRAY(struct io *) temp_ios;
123 switch (io_add_notify(file->path, notify_extract_callback, box, &io)) {
125 array_append(&temp_ios, &io,
149 struct io *io = *iop; local
[all...]
/dovecot/src/lib-oauth2/
H A Doauth2-private.h12 struct io *io; member in struct:oauth2_request
/dovecot/src/old-stats/
H A Dclient.h8 struct io *io; member in struct:client
/dovecot/src/ipc/
H A Dipc-connection.h23 struct io *io; member in struct:ipc_connection
H A Dclient.c19 struct io *io; member in struct:client
51 if (status != IPC_CMD_STATUS_REPLY && client->io == NULL) {
52 client->io = io_add(client->fd, IO_READ, client_input, client);
110 io_remove(&client->io);
124 client->io = io_add(fd, IO_READ, client_input, client);
140 io_remove(&client->io);
/dovecot/src/lib-auth/
H A Dauth-server-connection.h11 struct io *io; member in struct:auth_server_connection
/dovecot/src/lib-program-client/
H A Dprogram-client-private.h28 struct io *io; member in struct:program_client_extra_fd
43 struct io *io; member in struct:program_client
/dovecot/src/master/
H A Dservice-anvil.h17 struct io *io_blocking, *io_nonblocking;

Completed in 47 milliseconds

123456