Lines Matching refs:out
37 struct ostream *out;
61 test_ostream_set_max_output_size(ctx->out, size-1);
69 const char *run_pump(struct istream *in, struct ostream *out, int *counter, buffer_t *out_buffer)
74 struct nonblock_ctx ctx = { in, out, 0, 0 };
81 test_ostream_set_max_output_size(out, 0);
85 pump = iostream_pump_create(in, out);
87 o_stream_unref(&out);
104 ctx.out->stream_errno == 0) {
106 test_ostream_set_max_output_size(ctx.out, (size_t)-1);
107 test_assert(o_stream_flush(ctx.out) > 0);
109 test_assert(o_stream_flush(ctx.out) != 0);
142 struct ostream *out;
145 test_iostream_setup(block, &in, &out, &buffer);
148 test_assert(strcmp(run_pump(in, out, &counter, buffer), "hello, world") == 0);
160 struct ostream *out;
163 test_iostream_setup(block, &in_2, &out, &buffer);
167 test_assert(strcmp(run_pump(in, out, &counter, buffer), "") == 0);
179 struct ostream *out;
182 test_iostream_setup(block, &in_2, &out, &buffer);
186 test_assert(strcmp(run_pump(in, out, &counter, buffer), "hell") == 0);
198 struct ostream *out;
201 test_iostream_setup(block, &in_2, &out, &buffer);
205 test_assert(strcmp(run_pump(in, out, &counter, buffer), "hello, world") == 0);
221 struct ostream *out = o_stream_create_failure_at(out_2, 0, "test pump fail");
224 test_assert(strcmp(run_pump(in, out, &counter, buffer), "") == 0);
240 struct ostream *out = o_stream_create_failure_at(out_2, 4, "test pump fail");
245 test_assert(strcmp(run_pump(in, out, &counter, buffer), block ? "" : "hel") == 0);
265 struct ostream *out = o_stream_create_failure_at_flush(out_2, "test pump fail");
268 test_assert(strcmp(run_pump(in, out, &counter, buffer), "hello, world") == 0);