Searched defs:fds (Results 1 - 9 of 9) sorted by relevance

/dovecot/src/lib/
H A Dtest-ostream-multiplex.c108 int fds[2]; local
109 test_assert(pipe(fds) == 0);
110 fd_set_nonblock(fds[0], TRUE);
111 fd_set_nonblock(fds[1], TRUE);
112 struct ostream *os = o_stream_create_fd(fds[1], (size_t)-1);
113 struct istream *is = i_stream_create_fd(fds[0], (size_t)-1);
121 io_add(fds[1], IO_WRITE, test_ostream_multiplex_stream_write, os);
138 i_close_fd(&fds[0]);
139 i_close_fd(&fds[1]);
H A Dioloop-poll.c15 struct pollfd *fds; member in struct:ioloop_handler_context
27 ctx->fds = i_new(struct pollfd, ctx->fds_count);
36 i_free(ioloop->handler_context->fds);
70 ctx->fds = i_realloc_type(ctx->fds, struct pollfd,
82 ctx->fds[index].fd = fd;
83 ctx->fds[index].events = 0;
84 ctx->fds[index].revents = 0;
87 old_events = ctx->fds[index].events;
89 ctx->fds[inde
[all...]
H A Dtest-ioloop.c49 int fds[2]; local
50 int ret = socketpair(AF_UNIX, SOCK_STREAM, 0, fds);
64 io_add(fds[0], IO_READ,
67 io_add(fds[1], IO_READ,
72 if (write(fds[0], "ltr", 3) != 3 ||
73 write(fds[1], "rtl", 3) != 3)
87 i_close_fd(&fds[0]);
88 i_close_fd(&fds[1]);
H A Dtest-multiplex.c16 int fds[2]; member in struct:test_channel
85 test_assert(pipe(channel->fds) == 0);
86 fd_set_nonblock(channel->fds[0], TRUE);
87 fd_set_nonblock(channel->fds[1], TRUE);
88 channel->in_alt = i_stream_create_fd(channel->fds[0], (size_t)-1);
89 channel->out_alt = o_stream_create_fd(channel->fds[1], IO_BLOCK_SIZE);
114 i_close_fd(&channel->fds[0]);
115 i_close_fd(&channel->fds[1]);
124 int fds[2]; local
125 test_assert(pipe(fds)
[all...]
H A Dtest-istream-multiplex.c285 int fds[2]; local
286 test_assert(pipe(fds) == 0);
287 fd_set_nonblock(fds[0], TRUE);
288 fd_set_nonblock(fds[1], TRUE);
289 struct ostream *os = o_stream_create_fd(fds[1], (size_t)-1);
290 struct istream *is = i_stream_create_fd(fds[0], 10 + i_rand() % 10);
300 io_add(fds[1], IO_WRITE, test_istream_multiplex_stream_write, os);
317 i_close_fd(&fds[0]);
318 i_close_fd(&fds[1]);
/dovecot/src/login-common/
H A Dclient-common.c591 int fds[2]; local
604 if (socketpair(AF_UNIX, SOCK_STREAM, 0, fds) < 0) {
608 fd_set_nonblock(fds[0], TRUE);
609 fd_set_nonblock(fds[1], TRUE);
611 struct ostream *output = o_stream_create_fd(fds[0], IO_BLOCK_SIZE);
613 i_stream_create_fd_autoclose(&fds[0], IO_BLOCK_SIZE);
630 *fd_r = fds[1];
/dovecot/src/lib-smtp/
H A Dtest-smtp-client-errors.c2827 int fds[server_tests_count]; local
2837 fds[i] = test_open_server_fd(&bind_ports[i]);
2840 fd_listen = fds[i];
H A Dtest-smtp-submit.c2049 int fds[server_tests_count]; local
2061 fds[i] = test_open_server_fd(&bind_ports[i]);
2064 fd_listen = fds[i];
/dovecot/src/lib-http/
H A Dtest-http-client-errors.c3118 int fds[server_tests_count]; local
3128 fds[i] = test_open_server_fd(&bind_ports[i]);
3131 fd_listen = fds[i];

Completed in 35 milliseconds