| 848 | } |
| 849 | |
| 850 | static void c2_beam_output_write_notify(void *ctx, h2_bucket_beam *beam) |
| 851 | { |
| 852 | conn_rec *c = ctx; |
| 853 | h2_conn_ctx_t *conn_ctx = h2_conn_ctx_get(c); |
| 854 | |
| 855 | if (conn_ctx && conn_ctx->stream_id) { |
| 856 | add_stream_poll_event(conn_ctx->mplx, conn_ctx->stream_id, |
| 857 | conn_ctx->mplx->streams_output_written); |
| 858 | } |
| 859 | } |
| 860 | |
| 861 | static apr_status_t c2_setup_io(h2_mplx *m, conn_rec *c2, h2_stream *stream, h2_c2_transit *transit) |
| 862 | { |
no test coverage detected