| 803 | } |
| 804 | |
| 805 | static void c2_beam_input_write_notify(void *ctx, h2_bucket_beam *beam) |
| 806 | { |
| 807 | conn_rec *c = ctx; |
| 808 | h2_conn_ctx_t *conn_ctx = h2_conn_ctx_get(c); |
| 809 | |
| 810 | (void)beam; |
| 811 | if (conn_ctx && conn_ctx->stream_id && conn_ctx->pipe_in[H2_PIPE_IN]) { |
| 812 | apr_file_putc(1, conn_ctx->pipe_in[H2_PIPE_IN]); |
| 813 | } |
| 814 | } |
| 815 | |
| 816 | static void add_stream_poll_event(h2_mplx *m, int stream_id, h2_iqueue *q) |
| 817 | { |