Home
last modified time | relevance | path

Searched refs:dep_stream (Results 1 – 9 of 9) sorted by relevance

/third_party/nghttp2/lib/
Dnghttp2_stream.c146 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()
[all …]
Dnghttp2_stream.h336 int nghttp2_stream_dep_insert(nghttp2_stream *dep_stream,
343 void nghttp2_stream_dep_add(nghttp2_stream *dep_stream, nghttp2_stream *stream);
385 int nghttp2_stream_dep_insert_subtree(nghttp2_stream *dep_stream,
398 int nghttp2_stream_dep_add_subtree(nghttp2_stream *dep_stream,
Dnghttp2_session.c774 nghttp2_stream *dep_stream = NULL; in nghttp2_session_reprioritize_stream() local
785 dep_stream = nghttp2_session_get_stream_raw(session, pri_spec->stream_id); in nghttp2_session_reprioritize_stream()
787 if (!dep_stream && in nghttp2_session_reprioritize_stream()
792 dep_stream = nghttp2_session_open_stream( in nghttp2_session_reprioritize_stream()
796 if (dep_stream == NULL) { in nghttp2_session_reprioritize_stream()
799 } else if (!dep_stream || !nghttp2_stream_in_dep_tree(dep_stream)) { in nghttp2_session_reprioritize_stream()
806 dep_stream = &session->root; in nghttp2_session_reprioritize_stream()
807 } else if (nghttp2_stream_dep_find_ancestor(dep_stream, stream)) { in nghttp2_session_reprioritize_stream()
809 dep_stream, dep_stream->stream_id, stream, stream->stream_id); in nghttp2_session_reprioritize_stream()
811 nghttp2_stream_dep_remove_subtree(dep_stream); in nghttp2_session_reprioritize_stream()
[all …]
/third_party/node/deps/nghttp2/lib/
Dnghttp2_stream.c146 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()
[all …]
Dnghttp2_stream.h336 int nghttp2_stream_dep_insert(nghttp2_stream *dep_stream,
343 void nghttp2_stream_dep_add(nghttp2_stream *dep_stream, nghttp2_stream *stream);
385 int nghttp2_stream_dep_insert_subtree(nghttp2_stream *dep_stream,
398 int nghttp2_stream_dep_add_subtree(nghttp2_stream *dep_stream,
Dnghttp2_session.c774 nghttp2_stream *dep_stream = NULL; in nghttp2_session_reprioritize_stream() local
785 dep_stream = nghttp2_session_get_stream_raw(session, pri_spec->stream_id); in nghttp2_session_reprioritize_stream()
787 if (!dep_stream && in nghttp2_session_reprioritize_stream()
792 dep_stream = nghttp2_session_open_stream( in nghttp2_session_reprioritize_stream()
796 if (dep_stream == NULL) { in nghttp2_session_reprioritize_stream()
799 } else if (!dep_stream || !nghttp2_stream_in_dep_tree(dep_stream)) { in nghttp2_session_reprioritize_stream()
806 dep_stream = &session->root; in nghttp2_session_reprioritize_stream()
807 } else if (nghttp2_stream_dep_find_ancestor(dep_stream, stream)) { in nghttp2_session_reprioritize_stream()
809 dep_stream, dep_stream->stream_id, stream, stream->stream_id); in nghttp2_session_reprioritize_stream()
811 nghttp2_stream_dep_remove_subtree(dep_stream); in nghttp2_session_reprioritize_stream()
[all …]
/third_party/nghttp2/tests/
Dnghttp2_test_helper.c264 nghttp2_stream *dep_stream) { in open_stream_with_all() argument
268 if (dep_stream) { in open_stream_with_all()
269 dep_stream_id = dep_stream->stream_id; in open_stream_with_all()
288 nghttp2_stream *dep_stream) { in open_stream_with_dep() argument
290 dep_stream); in open_stream_with_dep()
295 nghttp2_stream *dep_stream) { in open_stream_with_dep_weight() argument
296 return open_stream_with_all(session, stream_id, weight, 0, dep_stream); in open_stream_with_dep_weight()
301 nghttp2_stream *dep_stream) { in open_stream_with_dep_excl() argument
303 dep_stream); in open_stream_with_dep_excl()
353 nghttp2_stream *dep_stream) { in open_sent_stream_with_dep() argument
[all …]
Dnghttp2_test_helper.h101 nghttp2_stream *dep_stream);
105 nghttp2_stream *dep_stream);
109 nghttp2_stream *dep_stream);
129 nghttp2_stream *dep_stream);
134 nghttp2_stream *dep_stream);
151 nghttp2_stream *dep_stream);
156 nghttp2_stream *dep_stream);
Dnghttp2_session_test.c3274 nghttp2_stream *stream, *dep_stream; in test_nghttp2_session_on_priority_received() local
3295 dep_stream = open_recv_stream(session, 3); in test_nghttp2_session_on_priority_received()
3303 CU_ASSERT(dep_stream == stream->dep_prev); in test_nghttp2_session_on_priority_received()
3314 CU_ASSERT(dep_stream == stream->dep_prev); in test_nghttp2_session_on_priority_received()
4634 nghttp2_stream *dep_stream; in test_nghttp2_session_reprioritize_stream() local
4663 dep_stream = nghttp2_session_get_stream_raw(session, 3); in test_nghttp2_session_reprioritize_stream()
4665 CU_ASSERT(NGHTTP2_DEFAULT_WEIGHT == dep_stream->weight); in test_nghttp2_session_reprioritize_stream()
4667 dep_stream = open_recv_stream(session, 3); in test_nghttp2_session_reprioritize_stream()
4676 CU_ASSERT(dep_stream == stream->dep_prev); in test_nghttp2_session_reprioritize_stream()
4685 CU_ASSERT(dep_stream == stream->dep_prev); in test_nghttp2_session_reprioritize_stream()
[all …]