Searched defs:pump (Results 1 - 3 of 3) sorted by relevance
| /dovecot/src/lib/ |
| H A D | iostream-pump.c | 6 #include "iostream-pump.h"
29 void iostream_pump_copy(struct iostream_pump *pump) argument
33 o_stream_cork(pump->output);
34 size_t old_size = o_stream_get_max_buffer_size(pump->output);
35 o_stream_set_max_buffer_size(pump->output,
37 o_stream_get_max_buffer_size(pump->output)));
38 res = o_stream_send_istream(pump->output, pump->input);
39 o_stream_set_max_buffer_size(pump->output, old_size);
40 o_stream_uncork(pump
80 iostream_pump_flush(struct iostream_pump *pump) argument
112 struct iostream_pump *pump = i_new(struct iostream_pump, 1); local
121 iostream_pump_start(struct iostream_pump *pump) argument
136 iostream_pump_get_input(struct iostream_pump *pump) argument
142 iostream_pump_get_output(struct iostream_pump *pump) argument
148 iostream_pump_set_completion_callback(struct iostream_pump *pump, iostream_pump_callback_t *callback, void *context) argument
156 iostream_pump_ref(struct iostream_pump *pump) argument
165 struct iostream_pump *pump = *pump_r; local
177 iostream_pump_stop(struct iostream_pump *pump) argument
186 iostream_pump_is_waiting_output(struct iostream_pump *pump) argument
191 iostream_pump_switch_ioloop(struct iostream_pump *pump) argument
[all...] |
| H A D | test-iostream-pump.c | 9 #include "iostream-pump.h"
71 struct iostream_pump *pump; local
85 pump = iostream_pump_create(in, out);
89 iostream_pump_set_completion_callback(pump, completed, counter);
90 iostream_pump_start(pump);
114 iostream_pump_unref(&pump);
164 struct istream *in = i_stream_create_failure_at(in_2, 0, EIO, "test pump fail");
183 struct istream *in = i_stream_create_failure_at(in_2, 4, EIO, "test pump fail");
202 struct istream *in = i_stream_create_failure_at_eof(in_2, EIO, "test pump fail");
221 struct ostream *out = o_stream_create_failure_at(out_2, 0, "test pump fai
[all...] |
| /dovecot/src/lib-http/ |
| H A D | http-server-request.c | 643 /* pump-based */
648 struct iostream_pump *pump; member in struct:http_server_payload_handler_pump
661 iostream_pump_unref(&phandler->pump);
671 iostream_pump_switch_ioloop(phandler->pump);
681 struct istream *input = iostream_pump_get_input(phandler->pump);
682 struct ostream *output = iostream_pump_get_output(phandler->pump);
766 phandler->pump = iostream_pump_create(input, output);
767 iostream_pump_set_completion_callback(phandler->pump,
769 iostream_pump_start(phandler->pump);
|
Completed in 13 milliseconds