| 127 | } |
| 128 | |
| 129 | static int add_for_purge(h2_mplx *m, h2_stream *stream) |
| 130 | { |
| 131 | int i; |
| 132 | for (i = 0; i < m->spurge->nelts; ++i) { |
| 133 | h2_stream *s = APR_ARRAY_IDX(m->spurge, i, h2_stream*); |
| 134 | if (s == stream) /* already scheduled for purging */ |
| 135 | return FALSE; |
| 136 | } |
| 137 | APR_ARRAY_PUSH(m->spurge, h2_stream *) = stream; |
| 138 | return TRUE; |
| 139 | } |
| 140 | |
| 141 | static void c1c2_stream_joined(h2_mplx *m, h2_stream *stream) |
| 142 | { |
no outgoing calls
no test coverage detected