| 824 | } |
| 825 | |
| 826 | static void c2_beam_input_read_notify(void *ctx, h2_bucket_beam *beam) |
| 827 | { |
| 828 | conn_rec *c = ctx; |
| 829 | h2_conn_ctx_t *conn_ctx = h2_conn_ctx_get(c); |
| 830 | |
| 831 | if (conn_ctx && conn_ctx->stream_id) { |
| 832 | add_stream_poll_event(conn_ctx->mplx, conn_ctx->stream_id, |
| 833 | conn_ctx->mplx->streams_input_read); |
| 834 | } |
| 835 | } |
| 836 | |
| 837 | static void c2_beam_input_read_eagain(void *ctx, h2_bucket_beam *beam) |
| 838 | { |
nothing calls this directly
no test coverage detected