Lines Matching refs:dep_stream
147 static int stream_obq_push(nghttp2_stream *dep_stream, nghttp2_stream *stream) {
150 for (; dep_stream && !stream->queued;
151 stream = dep_stream, dep_stream = dep_stream->dep_prev) {
152 stream_next_cycle(stream, dep_stream->descendant_last_cycle);
153 stream->seq = dep_stream->descendant_next_seq++;
159 dep_stream->stream_id);
161 rv = nghttp2_pq_push(&dep_stream->obq, &stream->pq_entry);
177 nghttp2_stream *dep_stream;
179 dep_stream = stream->dep_prev;
185 for (; dep_stream; stream = dep_stream, dep_stream = dep_stream->dep_prev) {
187 dep_stream->stream_id);
189 nghttp2_pq_remove(&dep_stream->obq, &stream->pq_entry);
199 if (stream_subtree_active(dep_stream)) {
227 nghttp2_stream *dep_stream;
231 dep_stream = stream->dep_prev;
233 for (; dep_stream; stream = dep_stream, dep_stream = dep_stream->dep_prev) {
234 nghttp2_pq_remove(&dep_stream->obq, &stream->pq_entry);
236 stream_next_cycle(stream, dep_stream->descendant_last_cycle);
237 stream->seq = dep_stream->descendant_next_seq++;
239 nghttp2_pq_push(&dep_stream->obq, &stream->pq_entry);
244 dep_stream->last_writelen = stream->last_writelen;
249 nghttp2_stream *dep_stream;
261 dep_stream = stream->dep_prev;
263 if (!dep_stream) {
267 dep_stream->sum_dep_weight += weight - old_weight;
273 nghttp2_pq_remove(&dep_stream->obq, &stream->pq_entry);
291 if (dep_stream->descendant_last_cycle - stream->cycle <=
293 stream->cycle = dep_stream->descendant_last_cycle;
298 nghttp2_pq_push(&dep_stream->obq, &stream->pq_entry);
604 int nghttp2_stream_dep_insert(nghttp2_stream *dep_stream,
609 DEBUGF("stream: dep_insert dep_stream(%p)=%d, stream(%p)=%d\n", dep_stream,
610 dep_stream->stream_id, stream, stream->stream_id);
612 stream->sum_dep_weight = dep_stream->sum_dep_weight;
613 dep_stream->sum_dep_weight = stream->weight;
615 if (dep_stream->dep_next) {
616 for (si = dep_stream->dep_next; si; si = si->sib_next) {
619 rv = stream_obq_move(stream, dep_stream, si);
627 rv = stream_obq_push(dep_stream, stream);
633 stream->dep_next = dep_stream->dep_next;
636 dep_stream->dep_next = stream;
637 stream->dep_prev = dep_stream;
650 static void link_dep(nghttp2_stream *dep_stream, nghttp2_stream *stream) {
651 dep_stream->dep_next = stream;
653 stream->dep_prev = dep_stream;
664 static void insert_link_dep(nghttp2_stream *dep_stream,
670 sib_next = dep_stream->dep_next;
674 link_dep(dep_stream, stream);
753 void nghttp2_stream_dep_add(nghttp2_stream *dep_stream,
755 DEBUGF("stream: dep_add dep_stream(%p)=%d, stream(%p)=%d\n", dep_stream,
756 dep_stream->stream_id, stream, stream->stream_id);
758 dep_stream->sum_dep_weight += stream->weight;
760 if (dep_stream->dep_next == NULL) {
761 link_dep(dep_stream, stream);
763 insert_link_dep(dep_stream, stream);
820 int nghttp2_stream_dep_insert_subtree(nghttp2_stream *dep_stream,
827 DEBUGF("stream: dep_insert_subtree dep_stream(%p)=%d stream(%p)=%d\n",
828 dep_stream, dep_stream->stream_id, stream, stream->stream_id);
830 stream->sum_dep_weight += dep_stream->sum_dep_weight;
831 dep_stream->sum_dep_weight = stream->weight;
833 if (dep_stream->dep_next) {
834 dep_next = dep_stream->dep_next;
836 link_dep(dep_stream, stream);
849 rv = stream_obq_move(stream, dep_stream, si);
856 link_dep(dep_stream, stream);
860 rv = stream_obq_push(dep_stream, stream);
866 validate_tree(dep_stream);
871 int nghttp2_stream_dep_add_subtree(nghttp2_stream *dep_stream,
875 DEBUGF("stream: dep_add_subtree dep_stream(%p)=%d stream(%p)=%d\n",
876 dep_stream, dep_stream->stream_id, stream, stream->stream_id);
878 dep_stream->sum_dep_weight += stream->weight;
880 if (dep_stream->dep_next) {
881 insert_link_dep(dep_stream, stream);
883 link_dep(dep_stream, stream);
887 rv = stream_obq_push(dep_stream, stream);
893 validate_tree(dep_stream);