| 1132 | } |
| 1133 | |
| 1134 | apr_status_t h2_stream_read_to(h2_stream *stream, apr_bucket_brigade *bb, |
| 1135 | apr_off_t *plen, int *peos) |
| 1136 | { |
| 1137 | apr_status_t rv = APR_SUCCESS; |
| 1138 | |
| 1139 | H2_STRM_ASSERT_MAGIC(stream, H2_STRM_MAGIC_OK); |
| 1140 | if (stream->rst_error) { |
| 1141 | return APR_ECONNRESET; |
| 1142 | } |
| 1143 | rv = h2_append_brigade(bb, stream->out_buffer, plen, peos, bucket_pass_to_c1); |
| 1144 | if (APR_SUCCESS == rv && !*peos && !*plen) { |
| 1145 | rv = APR_EAGAIN; |
| 1146 | } |
| 1147 | return rv; |
| 1148 | } |
| 1149 | |
| 1150 | static apr_status_t stream_do_trailers(h2_stream *stream) |
| 1151 | { |
no test coverage detected