| 1051 | } |
| 1052 | |
| 1053 | static void c2_prod_done(void *baton, conn_rec *c2) |
| 1054 | { |
| 1055 | h2_mplx *m = baton; |
| 1056 | h2_conn_ctx_t *conn_ctx = h2_conn_ctx_get(c2); |
| 1057 | |
| 1058 | AP_DEBUG_ASSERT(conn_ctx); |
| 1059 | H2_MPLX_ENTER_ALWAYS(m); |
| 1060 | |
| 1061 | --m->processing_count; |
| 1062 | s_c2_done(m, c2, conn_ctx); |
| 1063 | if (m->join_wait) apr_thread_cond_signal(m->join_wait); |
| 1064 | |
| 1065 | H2_MPLX_LEAVE(m); |
| 1066 | } |
| 1067 | |
| 1068 | static void workers_shutdown(void *baton, int graceful) |
| 1069 | { |
nothing calls this directly
no test coverage detected