Lines Matching refs:dep_stream
146 static int stream_obq_push(nghttp2_stream *dep_stream, nghttp2_stream *stream) { in stream_obq_push() argument
149 for (; dep_stream && !stream->queued; in stream_obq_push()
150 stream = dep_stream, dep_stream = dep_stream->dep_prev) { in stream_obq_push()
151 stream_next_cycle(stream, dep_stream->descendant_last_cycle); in stream_obq_push()
152 stream->seq = dep_stream->descendant_next_seq++; in stream_obq_push()
158 dep_stream->stream_id); in stream_obq_push()
160 rv = nghttp2_pq_push(&dep_stream->obq, &stream->pq_entry); in stream_obq_push()
176 nghttp2_stream *dep_stream; in stream_obq_remove() local
178 dep_stream = stream->dep_prev; in stream_obq_remove()
184 for (; dep_stream; stream = dep_stream, dep_stream = dep_stream->dep_prev) { in stream_obq_remove()
186 dep_stream->stream_id); in stream_obq_remove()
188 nghttp2_pq_remove(&dep_stream->obq, &stream->pq_entry); in stream_obq_remove()
198 if (stream_subtree_active(dep_stream)) { in stream_obq_remove()
226 nghttp2_stream *dep_stream; in nghttp2_stream_reschedule() local
230 dep_stream = stream->dep_prev; in nghttp2_stream_reschedule()
232 for (; dep_stream; stream = dep_stream, dep_stream = dep_stream->dep_prev) { in nghttp2_stream_reschedule()
233 nghttp2_pq_remove(&dep_stream->obq, &stream->pq_entry); in nghttp2_stream_reschedule()
235 stream_next_cycle(stream, dep_stream->descendant_last_cycle); in nghttp2_stream_reschedule()
236 stream->seq = dep_stream->descendant_next_seq++; in nghttp2_stream_reschedule()
238 nghttp2_pq_push(&dep_stream->obq, &stream->pq_entry); in nghttp2_stream_reschedule()
243 dep_stream->last_writelen = stream->last_writelen; in nghttp2_stream_reschedule()
248 nghttp2_stream *dep_stream; in nghttp2_stream_change_weight() local
260 dep_stream = stream->dep_prev; in nghttp2_stream_change_weight()
262 if (!dep_stream) { in nghttp2_stream_change_weight()
266 dep_stream->sum_dep_weight += weight - old_weight; in nghttp2_stream_change_weight()
272 nghttp2_pq_remove(&dep_stream->obq, &stream->pq_entry); in nghttp2_stream_change_weight()
290 if (dep_stream->descendant_last_cycle - stream->cycle <= in nghttp2_stream_change_weight()
292 stream->cycle = dep_stream->descendant_last_cycle; in nghttp2_stream_change_weight()
297 nghttp2_pq_push(&dep_stream->obq, &stream->pq_entry); in nghttp2_stream_change_weight()
589 int nghttp2_stream_dep_insert(nghttp2_stream *dep_stream, in nghttp2_stream_dep_insert() argument
594 DEBUGF("stream: dep_insert dep_stream(%p)=%d, stream(%p)=%d\n", dep_stream, in nghttp2_stream_dep_insert()
595 dep_stream->stream_id, stream, stream->stream_id); in nghttp2_stream_dep_insert()
597 stream->sum_dep_weight = dep_stream->sum_dep_weight; in nghttp2_stream_dep_insert()
598 dep_stream->sum_dep_weight = stream->weight; in nghttp2_stream_dep_insert()
600 if (dep_stream->dep_next) { in nghttp2_stream_dep_insert()
601 for (si = dep_stream->dep_next; si; si = si->sib_next) { in nghttp2_stream_dep_insert()
604 rv = stream_obq_move(stream, dep_stream, si); in nghttp2_stream_dep_insert()
612 rv = stream_obq_push(dep_stream, stream); in nghttp2_stream_dep_insert()
618 stream->dep_next = dep_stream->dep_next; in nghttp2_stream_dep_insert()
621 dep_stream->dep_next = stream; in nghttp2_stream_dep_insert()
622 stream->dep_prev = dep_stream; in nghttp2_stream_dep_insert()
635 static void link_dep(nghttp2_stream *dep_stream, nghttp2_stream *stream) { in link_dep() argument
636 dep_stream->dep_next = stream; in link_dep()
638 stream->dep_prev = dep_stream; in link_dep()
649 static void insert_link_dep(nghttp2_stream *dep_stream, in insert_link_dep() argument
655 sib_next = dep_stream->dep_next; in insert_link_dep()
659 link_dep(dep_stream, stream); in insert_link_dep()
738 void nghttp2_stream_dep_add(nghttp2_stream *dep_stream, in nghttp2_stream_dep_add() argument
740 DEBUGF("stream: dep_add dep_stream(%p)=%d, stream(%p)=%d\n", dep_stream, in nghttp2_stream_dep_add()
741 dep_stream->stream_id, stream, stream->stream_id); in nghttp2_stream_dep_add()
743 dep_stream->sum_dep_weight += stream->weight; in nghttp2_stream_dep_add()
745 if (dep_stream->dep_next == NULL) { in nghttp2_stream_dep_add()
746 link_dep(dep_stream, stream); in nghttp2_stream_dep_add()
748 insert_link_dep(dep_stream, stream); in nghttp2_stream_dep_add()
805 int nghttp2_stream_dep_insert_subtree(nghttp2_stream *dep_stream, in nghttp2_stream_dep_insert_subtree() argument
813 dep_stream, dep_stream->stream_id, stream, stream->stream_id); in nghttp2_stream_dep_insert_subtree()
815 stream->sum_dep_weight += dep_stream->sum_dep_weight; in nghttp2_stream_dep_insert_subtree()
816 dep_stream->sum_dep_weight = stream->weight; in nghttp2_stream_dep_insert_subtree()
818 if (dep_stream->dep_next) { in nghttp2_stream_dep_insert_subtree()
819 dep_next = dep_stream->dep_next; in nghttp2_stream_dep_insert_subtree()
821 link_dep(dep_stream, stream); in nghttp2_stream_dep_insert_subtree()
834 rv = stream_obq_move(stream, dep_stream, si); in nghttp2_stream_dep_insert_subtree()
841 link_dep(dep_stream, stream); in nghttp2_stream_dep_insert_subtree()
845 rv = stream_obq_push(dep_stream, stream); in nghttp2_stream_dep_insert_subtree()
851 validate_tree(dep_stream); in nghttp2_stream_dep_insert_subtree()
856 int nghttp2_stream_dep_add_subtree(nghttp2_stream *dep_stream, in nghttp2_stream_dep_add_subtree() argument
861 dep_stream, dep_stream->stream_id, stream, stream->stream_id); in nghttp2_stream_dep_add_subtree()
863 dep_stream->sum_dep_weight += stream->weight; in nghttp2_stream_dep_add_subtree()
865 if (dep_stream->dep_next) { in nghttp2_stream_dep_add_subtree()
866 insert_link_dep(dep_stream, stream); in nghttp2_stream_dep_add_subtree()
868 link_dep(dep_stream, stream); in nghttp2_stream_dep_add_subtree()
872 rv = stream_obq_push(dep_stream, stream); in nghttp2_stream_dep_add_subtree()
878 validate_tree(dep_stream); in nghttp2_stream_dep_add_subtree()