/dovecot/src/lib/ |
H A D | ioloop-iolist.c | 11 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 D | ioloop-notify-fd.c | 9 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 D | ioloop-notify-fd.h | 7 struct io io; member in struct:io_notify 19 struct io * 23 struct io_notify *io);
|
H A D | ostream-file-private.h | 14 struct io *io; member in struct:file_ostream
|
H A D | ioloop-kqueue.c | 58 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 D | ioloop-select.c | 23 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 D | iostream-pump.c | 17 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...] |
/dovecot/src/auth/ |
H A D | auth-master-connection.h | 16 struct io *io; member in struct:auth_master_connection
|
H A D | auth-client-connection.h | 12 struct io *io; member in struct:auth_client_connection
|
/dovecot/src/login-common/ |
H A D | access-lookup.c | 19 struct io *io; member in struct:access_lookup 93 lookup->io = io_add(fd, IO_READ, access_lookup_input, lookup); 112 io_remove(&lookup->io);
|
/dovecot/src/old-stats/ |
H A D | client.h | 8 struct io *io; member in struct:client
|
H A D | fifo-input-connection.c | 23 struct io *io; member in struct:fifo_input_connection 82 conn->io = io_add(fd, IO_READ, fifo_input_connection_input, conn); 94 io_remove(&conn->io);
|
H A D | stats-carbon.c | 23 struct io *io; member in struct:stats_send_ctx 36 io_remove(&ctx->io); 62 io_remove(&ctx->io); 104 ctx->io = io_add(ctx->fd, IO_WRITE,
|
/dovecot/src/ipc/ |
H A D | ipc-connection.h | 23 struct io *io; member in struct:ipc_connection
|
H A D | client.c | 19 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 D | auth-server-connection.h | 11 struct io *io; member in struct:auth_server_connection
|
/dovecot/src/lib-master/ |
H A D | ipc-client.c | 25 struct io *io; member in struct:ipc_client 93 client->io = io_add(client->fd, IO_READ, ipc_client_input, client); 113 io_remove(&client->io);
|
/dovecot/src/lib-oauth2/ |
H A D | oauth2-private.h | 12 struct io *io; member in struct:oauth2_request
|
/dovecot/src/lib-storage/ |
H A D | mailbox-watch.c | 19 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/dict/ |
H A D | dict-connection.h | 24 struct io *io; member in struct:dict_connection
|
/dovecot/src/director/ |
H A D | auth-connection.c | 20 struct io *io; member in struct:auth_connection 91 conn->io = io_add(conn->fd, IO_READ, auth_connection_input, conn); 103 io_remove(&conn->io);
|
H A D | notify-connection.c | 19 struct io *io; member in struct:notify_connection 81 conn->io = io_add(conn->fd, IO_READ, notify_connection_input, conn); 92 io_remove(&conn->io);
|
/dovecot/src/dns/ |
H A D | dns-client.c | 16 struct io *io; member in struct:dns_client 99 client->io = io_add(fd, IO_READ, dns_client_input, client); 109 io_remove(&client->io);
|
/dovecot/src/replication/aggregator/ |
H A D | notify-connection.c | 25 struct io *io; member in struct:notify_connection 111 conn->io = io_add(fd, IO_READ, notify_input, conn); 141 io_remove(&conn->io);
|
/dovecot/src/util/ |
H A D | tcpwrap.c | 16 struct io *io; member in struct:tcpwrap_client 76 client->io = io_add(fd, IO_READ, tcpwrap_client_input, client); 89 io_remove(&client->io);
|