/third_party/nghttp2/lib/ |
H A D | nghttp2_stream.c | 147 static int stream_obq_push(nghttp2_stream *dep_stream, nghttp2_stream *stream) { in stream_obq_push() argument 150 for (; dep_stream && !stream->queued; in stream_obq_push() 151 stream = dep_stream, dep_stream = dep_stream->dep_prev) { in stream_obq_push() 152 stream_next_cycle(stream, dep_stream->descendant_last_cycle); in stream_obq_push() 153 stream->seq = dep_stream->descendant_next_seq++; in stream_obq_push() 159 dep_stream->stream_id); in stream_obq_push() 161 rv = nghttp2_pq_push(&dep_stream->obq, &stream->pq_entry); in stream_obq_push() 177 nghttp2_stream *dep_stream; in stream_obq_remove() local 227 nghttp2_stream *dep_stream; nghttp2_stream_reschedule() local 249 nghttp2_stream *dep_stream; nghttp2_stream_change_weight() local 604 nghttp2_stream_dep_insert(nghttp2_stream *dep_stream, nghttp2_stream *stream) nghttp2_stream_dep_insert() argument 650 link_dep(nghttp2_stream *dep_stream, nghttp2_stream *stream) link_dep() argument 664 insert_link_dep(nghttp2_stream *dep_stream, nghttp2_stream *stream) insert_link_dep() argument 753 nghttp2_stream_dep_add(nghttp2_stream *dep_stream, nghttp2_stream *stream) nghttp2_stream_dep_add() argument 820 nghttp2_stream_dep_insert_subtree(nghttp2_stream *dep_stream, nghttp2_stream *stream) nghttp2_stream_dep_insert_subtree() argument 871 nghttp2_stream_dep_add_subtree(nghttp2_stream *dep_stream, nghttp2_stream *stream) nghttp2_stream_dep_add_subtree() argument [all...] |
H A D | nghttp2_stream.h | 335 * Makes the |stream| depend on the |dep_stream|. This dependency is 336 * exclusive. All existing direct descendants of |dep_stream| become 346 int nghttp2_stream_dep_insert(nghttp2_stream *dep_stream, 350 * Makes the |stream| depend on the |dep_stream|. This dependency is 353 void nghttp2_stream_dep_add(nghttp2_stream *dep_stream, nghttp2_stream *stream); 380 * Makes the |stream| depend on the |dep_stream|. This dependency is 389 int nghttp2_stream_dep_insert_subtree(nghttp2_stream *dep_stream, 393 * Makes the |stream| depend on the |dep_stream|. This dependency is 402 int nghttp2_stream_dep_add_subtree(nghttp2_stream *dep_stream,
|
H A D | nghttp2_session.c | 840 nghttp2_stream *dep_stream = NULL; in nghttp2_session_reprioritize_stream() local 853 dep_stream = nghttp2_session_get_stream_raw(session, pri_spec->stream_id); in nghttp2_session_reprioritize_stream() 855 if (!dep_stream && in nghttp2_session_reprioritize_stream() 860 dep_stream = nghttp2_session_open_stream( in nghttp2_session_reprioritize_stream() 864 if (dep_stream == NULL) { in nghttp2_session_reprioritize_stream() 867 } else if (!dep_stream || !nghttp2_stream_in_dep_tree(dep_stream)) { in nghttp2_session_reprioritize_stream() 874 dep_stream = &session->root; in nghttp2_session_reprioritize_stream() 875 } else if (nghttp2_stream_dep_find_ancestor(dep_stream, stream)) { in nghttp2_session_reprioritize_stream() 876 DEBUGF("stream: cycle detected, dep_stream( in nghttp2_session_reprioritize_stream() 1297 nghttp2_stream *dep_stream = NULL; nghttp2_session_open_stream() local [all...] |
/third_party/node/deps/nghttp2/lib/ |
H A D | nghttp2_stream.c | 147 static int stream_obq_push(nghttp2_stream *dep_stream, nghttp2_stream *stream) { in stream_obq_push() argument 150 for (; dep_stream && !stream->queued; in stream_obq_push() 151 stream = dep_stream, dep_stream = dep_stream->dep_prev) { in stream_obq_push() 152 stream_next_cycle(stream, dep_stream->descendant_last_cycle); in stream_obq_push() 153 stream->seq = dep_stream->descendant_next_seq++; in stream_obq_push() 159 dep_stream->stream_id); in stream_obq_push() 161 rv = nghttp2_pq_push(&dep_stream->obq, &stream->pq_entry); in stream_obq_push() 177 nghttp2_stream *dep_stream; in stream_obq_remove() local 227 nghttp2_stream *dep_stream; nghttp2_stream_reschedule() local 249 nghttp2_stream *dep_stream; nghttp2_stream_change_weight() local 604 nghttp2_stream_dep_insert(nghttp2_stream *dep_stream, nghttp2_stream *stream) nghttp2_stream_dep_insert() argument 650 link_dep(nghttp2_stream *dep_stream, nghttp2_stream *stream) link_dep() argument 664 insert_link_dep(nghttp2_stream *dep_stream, nghttp2_stream *stream) insert_link_dep() argument 753 nghttp2_stream_dep_add(nghttp2_stream *dep_stream, nghttp2_stream *stream) nghttp2_stream_dep_add() argument 820 nghttp2_stream_dep_insert_subtree(nghttp2_stream *dep_stream, nghttp2_stream *stream) nghttp2_stream_dep_insert_subtree() argument 871 nghttp2_stream_dep_add_subtree(nghttp2_stream *dep_stream, nghttp2_stream *stream) nghttp2_stream_dep_add_subtree() argument [all...] |
H A D | nghttp2_stream.h | 335 * Makes the |stream| depend on the |dep_stream|. This dependency is 336 * exclusive. All existing direct descendants of |dep_stream| become 346 int nghttp2_stream_dep_insert(nghttp2_stream *dep_stream, 350 * Makes the |stream| depend on the |dep_stream|. This dependency is 353 void nghttp2_stream_dep_add(nghttp2_stream *dep_stream, nghttp2_stream *stream); 380 * Makes the |stream| depend on the |dep_stream|. This dependency is 389 int nghttp2_stream_dep_insert_subtree(nghttp2_stream *dep_stream, 393 * Makes the |stream| depend on the |dep_stream|. This dependency is 402 int nghttp2_stream_dep_add_subtree(nghttp2_stream *dep_stream,
|
H A D | nghttp2_session.c | 835 nghttp2_stream *dep_stream = NULL; in nghttp2_session_reprioritize_stream() local 848 dep_stream = nghttp2_session_get_stream_raw(session, pri_spec->stream_id); in nghttp2_session_reprioritize_stream() 850 if (!dep_stream && in nghttp2_session_reprioritize_stream() 855 dep_stream = nghttp2_session_open_stream( in nghttp2_session_reprioritize_stream() 859 if (dep_stream == NULL) { in nghttp2_session_reprioritize_stream() 862 } else if (!dep_stream || !nghttp2_stream_in_dep_tree(dep_stream)) { in nghttp2_session_reprioritize_stream() 869 dep_stream = &session->root; in nghttp2_session_reprioritize_stream() 870 } else if (nghttp2_stream_dep_find_ancestor(dep_stream, stream)) { in nghttp2_session_reprioritize_stream() 871 DEBUGF("stream: cycle detected, dep_stream( in nghttp2_session_reprioritize_stream() 1292 nghttp2_stream *dep_stream = NULL; nghttp2_session_open_stream() local [all...] |
/third_party/nghttp2/tests/ |
H A D | nghttp2_test_helper.c | 268 nghttp2_stream *dep_stream) { in open_stream_with_all() 272 if (dep_stream) { in open_stream_with_all() 273 dep_stream_id = dep_stream->stream_id; in open_stream_with_all() 292 nghttp2_stream *dep_stream) { in open_stream_with_dep() 294 dep_stream); in open_stream_with_dep() 299 nghttp2_stream *dep_stream) { in open_stream_with_dep_weight() 300 return open_stream_with_all(session, stream_id, weight, 0, dep_stream); in open_stream_with_dep_weight() 305 nghttp2_stream *dep_stream) { in open_stream_with_dep_excl() 307 dep_stream); in open_stream_with_dep_excl() 357 nghttp2_stream *dep_stream) { in open_sent_stream_with_dep() 265 open_stream_with_all(nghttp2_session *session, int32_t stream_id, int32_t weight, uint8_t exclusive, nghttp2_stream *dep_stream) open_stream_with_all() argument 290 open_stream_with_dep(nghttp2_session *session, int32_t stream_id, nghttp2_stream *dep_stream) open_stream_with_dep() argument 297 open_stream_with_dep_weight(nghttp2_session *session, int32_t stream_id, int32_t weight, nghttp2_stream *dep_stream) open_stream_with_dep_weight() argument 303 open_stream_with_dep_excl(nghttp2_session *session, int32_t stream_id, nghttp2_stream *dep_stream) open_stream_with_dep_excl() argument 355 open_sent_stream_with_dep(nghttp2_session *session, int32_t stream_id, nghttp2_stream *dep_stream) open_sent_stream_with_dep() argument 362 open_sent_stream_with_dep_weight(nghttp2_session *session, int32_t stream_id, int32_t weight, nghttp2_stream *dep_stream) open_sent_stream_with_dep_weight() argument 414 open_recv_stream_with_dep(nghttp2_session *session, int32_t stream_id, nghttp2_stream *dep_stream) open_recv_stream_with_dep() argument 421 open_recv_stream_with_dep_weight(nghttp2_session *session, int32_t stream_id, int32_t weight, nghttp2_stream *dep_stream) open_recv_stream_with_dep_weight() argument [all...] |
H A D | nghttp2_test_helper.h | 101 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);
|
H A D | nghttp2_session_test.c | 3582 nghttp2_stream *stream, *dep_stream; in test_nghttp2_session_on_priority_received() local 3603 dep_stream = open_recv_stream(session, 3); in test_nghttp2_session_on_priority_received() 3611 CU_ASSERT(dep_stream == stream->dep_prev); in test_nghttp2_session_on_priority_received() 3622 CU_ASSERT(dep_stream == stream->dep_prev); in test_nghttp2_session_on_priority_received() 5052 nghttp2_stream *dep_stream; in test_nghttp2_session_reprioritize_stream() local 5081 dep_stream = nghttp2_session_get_stream_raw(session, 3); in test_nghttp2_session_reprioritize_stream() 5083 CU_ASSERT(NGHTTP2_DEFAULT_WEIGHT == dep_stream->weight); in test_nghttp2_session_reprioritize_stream() 5085 dep_stream = open_recv_stream(session, 3); in test_nghttp2_session_reprioritize_stream() 5094 CU_ASSERT(dep_stream == stream->dep_prev); in test_nghttp2_session_reprioritize_stream() 5103 CU_ASSERT(dep_stream in test_nghttp2_session_reprioritize_stream() 10004 nghttp2_stream *dep_stream = NULL; test_nghttp2_session_large_dep_tree() local [all...] |