Lines Matching refs:obq
65 nghttp2_pq_init(&stream->obq, stream_less, mem);
108 nghttp2_pq_free(&stream->obq);
131 return stream_active(stream) || !nghttp2_pq_empty(&stream->obq);
155 DEBUGF("stream: stream=%d obq push cycle=%lu\n", stream->stream_id,
161 rv = nghttp2_pq_push(&dep_stream->obq, &stream->pq_entry);
172 * Removes |stream| from parent's obq. If removal of |stream| makes
173 * parent's obq empty, and parent is not active, then parent is also
189 nghttp2_pq_remove(&dep_stream->obq, &stream->pq_entry);
206 * Moves |stream| from |src|'s obq to |dest|'s obq. Removal from
207 * |src|'s obq is just done calling nghttp2_pq_remove(), so it does
220 nghttp2_pq_remove(&src->obq, &stream->pq_entry);
234 nghttp2_pq_remove(&dep_stream->obq, &stream->pq_entry);
239 nghttp2_pq_push(&dep_stream->obq, &stream->pq_entry);
241 DEBUGF("stream: stream=%d obq resched cycle=%lu\n", stream->stream_id,
273 nghttp2_pq_remove(&dep_stream->obq, &stream->pq_entry);
298 nghttp2_pq_push(&dep_stream->obq, &stream->pq_entry);
300 DEBUGF("stream: stream=%d obq resched cycle=%lu\n", stream->stream_id,
335 if (!nghttp2_pq_empty(&stream->obq)) {
337 stream->stream_id, nghttp2_pq_size(&stream->obq));
354 "stream_active() == %d and nghttp2_pq_size(&stream->obq) = %zu\n",
356 nghttp2_pq_size(&stream->obq));
379 if (stream_active(stream) || !nghttp2_pq_empty(&stream->obq)) {
383 "nghttp2_pq_size(&stream->obq) = %zu\n",
385 nghttp2_pq_size(&stream->obq));
438 if (nghttp2_pq_empty(&stream->obq)) {
439 fprintf(stderr, "root obq empty\n");
469 if (nghttp2_pq_empty(&stream->obq)) {
952 ent = nghttp2_pq_top(&stream->obq);