Searched defs:stream_errno (Results 1 - 17 of 17) sorted by relevance

/dovecot/src/lib/
H A Distream-failure-at.c39 stream->istream.stream_errno = errno =
54 } else if (ret < 0 && stream->istream.stream_errno == 0 &&
57 stream->istream.stream_errno = errno =
67 int stream_errno, const char *error_string)
82 fstream->error_code = stream_errno;
90 i_stream_create_failure_at_eof(struct istream *input, int stream_errno, argument
93 return i_stream_create_failure_at(input, (uoff_t)-1, stream_errno,
66 i_stream_create_failure_at(struct istream *input, uoff_t failure_offset, int stream_errno, const char *error_string) argument
H A Dtest-istream-base64-decoder.c11 int stream_errno; member in struct:__anon47
31 decode_test(const char *base64_input, const char *output, int stream_errno) argument
46 if (ret == -1 && stream_errno != 0)
55 test_assert(input->stream_errno == stream_errno);
71 decode_test(tests[i].input, tests[i].output, tests[i].stream_errno);
H A Dostream.h14 /* Read from istream failed. See istream->stream_errno. */
16 /* Write to ostream failed. See ostream->stream_errno. */
33 int stream_errno; member in struct:ostream
65 struct ostream *o_stream_create_error(int stream_errno);
67 o_stream_create_error_str(int stream_errno, const char *fmt, ...)
186 completed. If the stream hasn't already failed, sets the stream_errno=EPIPE.
H A Dtest-istream-jsonstr.c11 int stream_errno; member in struct:__anon48
31 run_test_buffer(const char *json_input, const char *output, int stream_errno, argument
47 if (ret == -1 && stream_errno != 0)
58 while (ret > 0 && stream_errno != 0)
61 test_assert(input->stream_errno == stream_errno);
63 if (stream_errno == 0) {
74 run_test(const char *json_input, const char *output, int stream_errno) argument
77 run_test_buffer(json_input, output, stream_errno, i);
134 run_test(tests[i].input, tests[i].output, tests[i].stream_errno);
[all...]
H A Dtest-istream-sized.c10 int stream_errno; member in struct:__anon49
21 run_test(const char *sized_input, uoff_t sized_size, int stream_errno) argument
36 if (ret == -1 && stream_errno != 0)
46 test_assert(input->stream_errno == stream_errno);
89 test_assert_idx(input->stream_errno == expected_errno, i);
101 run_test(tests[i].input, tests[i].size, tests[i].stream_errno);
H A Distream-callback.c50 stream->istream.stream_errno != 0)
109 void i_stream_callback_set_error(struct istream *input, int stream_errno, argument
112 input->stream_errno = stream_errno;
H A Distream.h22 If stream_errno != 0, eof==TRUE as well.
24 int stream_errno; member in struct:istream
33 available in buffer) or stream_errno != 0 */
69 struct istream *i_stream_create_error(int stream_errno);
71 i_stream_create_error_str(int stream_errno, const char *fmt, ...)
154 set stream_errno=ESPIPE. */
189 stream_errno is set to ENOBUFS. */
H A Distream-multiplex.c47 static void propagate_error(struct multiplex_istream *mstream, int stream_errno) argument
52 (*channelp)->istream.istream.stream_errno = stream_errno;
64 (*channelp)->istream.istream.stream_errno = EPIPE;
95 propagate_error(mstream, mstream->parent->stream_errno);
170 propagate_error(mstream, mstream->parent->stream_errno);
H A Dostream-multiplex.c47 static void propagate_error(struct multiplex_ostream *mstream, int stream_errno) argument
52 (*channelp)->ostream.ostream.stream_errno = stream_errno;
93 propagate_error(mstream, mstream->parent->stream_errno);
H A Dostream.c32 /* we'll only return errors for streams that have stream_errno set.
34 if (stream->stream_errno == 0)
38 if (s->stream_errno == 0)
43 return strerror(stream->stream_errno);
66 if (stream->stream_errno == 0)
67 stream->stream_errno = EPIPE;
157 if (unlikely(stream->closed || stream->stream_errno != 0))
167 if (unlikely(stream->closed || stream->stream_errno != 0))
187 if (unlikely(stream->closed || stream->stream_errno != 0)) {
188 errno = stream->stream_errno;
740 o_stream_create_error(int stream_errno) argument
757 o_stream_create_error_str(int stream_errno, const char *fmt, ...) argument
[all...]
H A Distream.c33 if (stream->stream_errno == 0)
34 stream->stream_errno = EPIPE;
95 /* we'll only return errors for streams that have stream_errno set or
98 if (stream->stream_errno == 0)
102 if (s->stream_errno == 0)
107 return strerror(stream->stream_errno);
294 if (unlikely(stream->closed || stream->stream_errno != 0)) {
296 errno = stream->stream_errno;
313 if (stream->stream_errno != 0) {
317 errno = stream->stream_errno;
1135 i_stream_create_error(int stream_errno) argument
1152 i_stream_create_error_str(int stream_errno, const char *fmt, ...) argument
[all...]
/dovecot/src/lib-mail/
H A Dtest-istream-qp-decoder.c11 int stream_errno; member in struct:__anon113
25 decode_test(const char *qp_input, const char *output, int stream_errno, argument
46 if (ret == -1 && stream_errno != 0)
58 test_assert(input->stream_errno == stream_errno);
73 tests[i].stream_errno, j);
H A Dtest-istream-qp-encoder.c11 int stream_errno; member in struct:__anon114
69 encode_test(const char *qp_input, const char *output, int stream_errno, argument
90 if (ret == -1 && stream_errno != 0)
103 test_assert(input->stream_errno == stream_errno);
118 tests[i].stream_errno, j);
/dovecot/src/lib-smtp/
H A Dsmtp-server-cmd-data.c157 unsigned int stream_errno = conn->state.data_input->stream_errno; local
169 if (stream_errno != EPIPE && stream_errno != ECONNRESET) {
221 if (conn->state.data_input->stream_errno != 0) {
H A Dsmtp-server-connection.c450 int stream_errno = conn->conn.input->stream_errno; local
451 if (stream_errno != 0 && stream_errno != EPIPE &&
452 stream_errno != ECONNRESET) {
600 if (output->stream_errno != EPIPE &&
601 output->stream_errno != ECONNRESET) {
/dovecot/src/lib-http/
H A Dhttp-server-connection.c202 int stream_errno; local
215 stream_errno = conn->incoming_payload->stream_errno;
222 if (req->response == NULL && stream_errno != 0 &&
223 conn->conn.input->stream_errno == 0) {
224 switch (stream_errno) {
453 int stream_errno; local
457 stream_errno = input->stream_errno;
459 if (input->eof || stream_errno !
[all...]
H A Dhttp-client-connection.c277 if (output->stream_errno != EPIPE &&
278 output->stream_errno != ECONNRESET) {
315 int stream_errno = conn->conn.input->stream_errno; local
317 i_assert(conn->conn.input->stream_errno != 0 || conn->conn.input->eof);
321 stream_errno != 0 ?
525 conn->conn.input->stream_errno = ETIMEDOUT;
920 int stream_errno = conn->conn.input->stream_errno; local
929 stream_errno !
1173 int stream_errno = conn->conn.input->stream_errno; local
[all...]

Completed in 356 milliseconds