| 110 | } |
| 111 | |
| 112 | static int stream_is_running(h2_stream *stream) |
| 113 | { |
| 114 | h2_conn_ctx_t *conn_ctx = h2_conn_ctx_get(stream->c2); |
| 115 | return conn_ctx && apr_atomic_read32(&conn_ctx->started) != 0 |
| 116 | && apr_atomic_read32(&conn_ctx->done) == 0; |
| 117 | } |
| 118 | |
| 119 | int h2_mplx_c1_stream_is_running(h2_mplx *m, h2_stream *stream) |
| 120 | { |
no outgoing calls
no test coverage detected