Lines Matching defs:stream_id
112 !nghttp2_session_is_my_stream_id(session, stream->stream_id);
119 nghttp2_session_is_my_stream_id(session, stream->stream_id);
123 * Checks whether received stream_id is valid. This function returns
127 int32_t stream_id) {
128 return stream_id != 0 &&
129 !nghttp2_session_is_my_stream_id(session, stream_id) &&
130 session->last_recv_stream_id < stream_id;
134 int32_t stream_id) {
135 /* Assume that stream object with stream_id does not exist */
136 if (nghttp2_session_is_my_stream_id(session, stream_id)) {
137 if (session->last_sent_stream_id < stream_id) {
142 if (session_is_new_peer_stream_id(session, stream_id)) {
274 int32_t stream_id) {
276 if (stream_id == 0) {
279 rem = stream_id & 0x1;
287 int32_t stream_id) {
290 stream = (nghttp2_stream *)nghttp2_map_find(&session->streams, stream_id);
301 int32_t stream_id) {
302 return (nghttp2_stream *)nghttp2_map_find(&session->streams, stream_id);
846 assert(pri_spec->stream_id != stream->stream_id);
852 if (pri_spec->stream_id != 0) {
853 dep_stream = nghttp2_session_get_stream_raw(session, pri_spec->stream_id);
856 session_detect_idle_stream(session, pri_spec->stream_id)) {
861 session, pri_spec->stream_id, NGHTTP2_FLAG_NONE, &pri_spec_default,
873 if (pri_spec->stream_id == 0) {
877 dep_stream, dep_stream->stream_id, stream, stream->stream_id);
1118 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
1177 nghttp2_priority_spec_init(&pri_spec, stream->stream_id,
1188 here, since stream->stream_id is local stream_id, and it does
1199 } else if (frame->hd.stream_id == 0) {
1212 int nghttp2_session_add_rst_stream(nghttp2_session *session, int32_t stream_id,
1221 stream = nghttp2_session_get_stream(session, stream_id);
1230 if (nghttp2_session_is_my_stream_id(session, stream_id)) {
1231 if ((uint32_t)stream_id >= session->next_stream_id) {
1234 } else if (session->last_recv_stream_id < stream_id) {
1240 if (!session->server && nghttp2_session_is_my_stream_id(session, stream_id) &&
1248 if (headers_frame->hd.stream_id <= stream_id) {
1253 if (item->frame.hd.stream_id < stream_id) {
1257 /* stream_id in ob_syn queue must be strictly increasing. If
1259 if (item->frame.hd.stream_id > stream_id || aux_data->canceled) {
1280 nghttp2_frame_rst_stream_init(&frame->rst_stream, stream_id, error_code);
1291 int32_t stream_id, uint8_t flags,
1304 stream = nghttp2_session_get_stream_raw(session, stream_id);
1351 } else if (pri_spec->stream_id != 0) {
1352 dep_stream = nghttp2_session_get_stream_raw(session, pri_spec->stream_id);
1355 session_detect_idle_stream(session, pri_spec->stream_id)) {
1361 session, pri_spec->stream_id, NGHTTP2_FLAG_NONE, &pri_spec_default,
1374 pri_spec->stream_id == stream_id. This happens because we
1375 don't check pri_spec->stream_id against new stream ID in
1391 nghttp2_stream_init(stream, stream_id, flags, initial_state,
1401 rv = nghttp2_map_insert(&session->streams, stream_id, stream);
1416 if (nghttp2_session_is_my_stream_id(session, stream_id)) {
1433 if (nghttp2_session_is_my_stream_id(session, stream_id)) {
1444 if (pri_spec->stream_id == 0) {
1462 int nghttp2_session_close_stream(nghttp2_session *session, int32_t stream_id,
1470 stream = nghttp2_session_get_stream(session, stream_id);
1476 DEBUGF("stream: stream(%p)=%d close\n", stream, stream->stream_id);
1504 session, stream_id, error_code, session->user_data) != 0) {
1510 is_my_stream_id = nghttp2_session_is_my_stream_id(session, stream_id);
1555 DEBUGF("stream: destroy closed stream(%p)=%d\n", stream, stream->stream_id);
1566 nghttp2_map_remove(&session->streams, stream->stream_id);
1576 stream->stream_id, stream->state);
1592 stream->stream_id, stream->state);
1610 stream->stream_id, stream->state);
1727 * Closes stream with stream ID |stream_id| if both transmission and
1742 return nghttp2_session_close_stream(session, stream->stream_id,
1808 * frame->hd.stream_id.
1862 if (nghttp2_session_is_my_stream_id(session, stream->stream_id)) {
1956 if (nghttp2_session_is_my_stream_id(session, stream->stream_id)) {
2016 * This function checks WINDOW_UPDATE with the stream ID |stream_id|
2033 int32_t stream_id) {
2040 if (stream_id == 0) {
2044 stream = nghttp2_session_get_stream(session, stream_id);
2058 int32_t stream_id) {
2065 if (stream_id == 0) {
2069 stream = nghttp2_session_get_stream(session, stream_id);
2088 int32_t stream_id) {
2095 stream = nghttp2_session_get_stream(session, stream_id);
2118 stream->stream_id, stream->remote_window_size);
2171 if (nghttp2_session_is_my_stream_id(session, stream->stream_id)) {
2318 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
2329 stream = nghttp2_session_get_stream_raw(session, frame->hd.stream_id);
2371 rv = nghttp2_session_add_rst_stream(session, frame->hd.stream_id,
2396 session, frame->hd.stream_id, NGHTTP2_STREAM_FLAG_NONE,
2418 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
2472 assert(session->last_sent_stream_id < frame->hd.stream_id);
2473 session->last_sent_stream_id = frame->hd.stream_id;
2523 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
2577 rv = session_predicate_window_update_send(session, frame->hd.stream_id);
2605 rv = session_predicate_altsvc_send(session, frame->hd.stream_id);
2628 priority_update->stream_id);
2752 if (nghttp2_session_is_my_stream_id(arg->session, stream->stream_id)) {
2762 stream->stream_id > arg->last_stream_id) {
2798 rv = nghttp2_session_close_stream(session, stream->stream_id,
2871 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
2940 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
2960 frame->hd.stream_id, &aux_data->data_prd);
2988 frame->hd.stream_id, &aux_data->data_prd);
3007 stream = nghttp2_session_get_stream_raw(session, frame->hd.stream_id);
3010 if (!session_detect_idle_stream(session, frame->hd.stream_id)) {
3015 session, frame->hd.stream_id, NGHTTP2_FLAG_NONE,
3036 rv = nghttp2_session_close_stream(session, frame->hd.stream_id,
3066 if (frame->hd.stream_id == 0) {
3081 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
3164 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
3281 opened_stream_id = item->frame.hd.stream_id;
3331 "stream_id=%d\n",
3333 frame->hd.stream_id);
3356 opened_stream_id = item->frame.hd.stream_id;
3444 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
3461 rv = nghttp2_session_add_rst_stream(session, frame->hd.stream_id,
3620 DEBUGF("recv: call on_begin_headers callback stream_id=%d\n",
3621 frame->hd.stream_id);
3782 int32_t stream_id,
3787 session, stream_id, get_error_code_from_lib_error_code(lib_error_code));
3803 return session_handle_invalid_stream2(session, frame->hd.stream_id, frame,
3887 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
3912 session, subject_stream->stream_id, NGHTTP2_COMPRESSION_ERROR);
3954 frame->hd.type, frame->hd.stream_id, (int)nv.name->len,
3961 frame->hd.type, frame->hd.stream_id, (int)nv.name->len,
3972 frame->hd.type, frame->hd.stream_id, (int)nv.name->len,
3979 frame->hd.type, frame->hd.stream_id, (int)nv.name->len,
3987 subject_stream->stream_id,
4066 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
4106 int32_t stream_id;
4109 stream_id = frame->push_promise.promised_stream_id;
4111 stream_id = frame->hd.stream_id;
4114 rv = session_handle_invalid_stream2(session, stream_id, frame,
4146 if (frame->hd.stream_id == 0) {
4148 session, frame, NGHTTP2_ERR_PROTO, "request HEADERS: stream_id == 0");
4155 if (session_detect_idle_stream(session, frame->hd.stream_id)) {
4166 if (!session_is_new_peer_stream_id(session, frame->hd.stream_id)) {
4167 if (frame->hd.stream_id == 0 ||
4168 nghttp2_session_is_my_stream_id(session, frame->hd.stream_id)) {
4171 "request HEADERS: invalid stream_id");
4194 stream = nghttp2_session_get_stream_raw(session, frame->hd.stream_id);
4202 session->last_recv_stream_id = frame->hd.stream_id;
4215 if (frame->headers.pri_spec.stream_id == frame->hd.stream_id) {
4226 session, frame->hd.stream_id, NGHTTP2_STREAM_FLAG_NONE,
4251 NGHTTP2_STREAM_OPENING and stream_id is local side initiated. */
4253 nghttp2_session_is_my_stream_id(session, frame->hd.stream_id));
4254 if (frame->hd.stream_id == 0) {
4256 session, frame, NGHTTP2_ERR_PROTO, "response HEADERS: stream_id == 0");
4283 if (frame->hd.stream_id == 0) {
4286 "push response HEADERS: stream_id == 0");
4312 if (!nghttp2_session_is_my_stream_id(session, stream->stream_id)) {
4327 if (frame->hd.stream_id == 0) {
4329 session, frame, NGHTTP2_ERR_PROTO, "HEADERS: stream_id == 0");
4343 if (nghttp2_session_is_my_stream_id(session, frame->hd.stream_id)) {
4375 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
4388 nghttp2_session_is_my_stream_id(session, frame->hd.stream_id)) {
4404 if (frame->hd.stream_id == 0) {
4406 "PRIORITY: stream_id == 0");
4409 if (frame->priority.pri_spec.stream_id == frame->hd.stream_id) {
4419 stream = nghttp2_session_get_stream_raw(session, frame->hd.stream_id);
4424 if (!session_detect_idle_stream(session, frame->hd.stream_id)) {
4429 session, frame->hd.stream_id, NGHTTP2_STREAM_FLAG_NONE,
4489 if (frame->hd.stream_id == 0) {
4491 "RST_STREAM: stream_id == 0");
4494 if (session_detect_idle_stream(session, frame->hd.stream_id)) {
4499 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
4509 rv = nghttp2_session_close_stream(session, frame->hd.stream_id,
4538 return nghttp2_session_add_rst_stream(arg->session, stream->stream_id,
4589 return nghttp2_session_add_rst_stream(arg->session, stream->stream_id,
4605 stream->stream_id,
4740 if (frame->hd.stream_id != 0) {
4742 "SETTINGS: stream_id != 0");
4975 if (frame->hd.stream_id == 0) {
4977 session, frame, NGHTTP2_ERR_PROTO, "PUSH_PROMISE: stream_id == 0");
4984 if (!nghttp2_session_is_my_stream_id(session, frame->hd.stream_id)) {
4986 session, frame, NGHTTP2_ERR_PROTO, "PUSH_PROMISE: invalid stream_id");
5004 if (session_detect_idle_stream(session, frame->hd.stream_id)) {
5010 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
5032 nghttp2_priority_spec_init(&pri_spec, stream->stream_id,
5067 if (frame->hd.stream_id != 0) {
5069 "PING: stream_id != 0");
5097 if (frame->hd.stream_id != 0) {
5099 "GOAWAY: stream_id != 0");
5163 if (session_detect_idle_stream(session, frame->hd.stream_id)) {
5168 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
5203 if (frame->hd.stream_id == 0) {
5229 if (frame->hd.stream_id == 0) {
5240 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
5275 if (frame->hd.stream_id != 0) {
5277 "PRIORITY_UPDATE: stream_id == 0");
5280 if (nghttp2_session_is_my_stream_id(session, priority_update->stream_id)) {
5281 if (session_detect_idle_stream(session, priority_update->stream_id)) {
5291 stream = nghttp2_session_get_stream_raw(session, priority_update->stream_id);
5297 } else if (session_detect_idle_stream(session, priority_update->stream_id)) {
5306 stream = nghttp2_session_open_stream(session, priority_update->stream_id,
5406 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
5417 rv = nghttp2_session_add_rst_stream(session, stream->stream_id,
5484 return nghttp2_session_add_rst_stream(session, stream->stream_id,
5497 stream->stream_id,
5538 int32_t stream_id, size_t delta_size,
5558 stream_id, recv_size);
5577 stream->window_update_queued, stream->stream_id, delta_size,
5590 * indicated by |session->iframe.frame.hd.stream_id|. If it is a
5609 int32_t stream_id;
5614 stream_id = iframe->frame.hd.stream_id;
5616 if (stream_id == 0) {
5620 failure_reason = "DATA: stream_id == 0";
5624 if (session_detect_idle_stream(session, stream_id)) {
5630 stream = nghttp2_session_get_stream(session, stream_id);
5632 stream = nghttp2_session_get_stream_raw(session, stream_id);
5647 if (nghttp2_session_is_my_stream_id(session, stream_id)) {
5922 DEBUGF("recv: payloadlen=%zu, type=%u, flags=0x%02x, stream_id=%d\n",
5924 iframe->frame.hd.flags, iframe->frame.hd.stream_id);
5955 DEBUGF("recv: DATA not allowed stream_id=%d\n",
5956 iframe->frame.hd.stream_id);
6049 session, iframe->frame.hd.stream_id, NGHTTP2_INTERNAL_ERROR);
6308 if (session->server || iframe->frame.hd.stream_id ||
6464 session, iframe->frame.hd.stream_id, NGHTTP2_INTERNAL_ERROR);
6735 : iframe->frame.hd.stream_id,
6923 DEBUGF("recv: payloadlen=%zu, type=%u, flags=0x%02x, stream_id=%d\n",
6924 cont_hd.length, cont_hd.type, cont_hd.flags, cont_hd.stream_id);
6927 cont_hd.stream_id != iframe->frame.hd.stream_id) {
6928 DEBUGF("recv: expected stream_id=%d, type=%d, but got stream_id=%d, "
6930 iframe->frame.hd.stream_id, NGHTTP2_CONTINUATION,
6931 cont_hd.stream_id, cont_hd.type);
6934 "unexpected non-CONTINUATION frame or stream_id is invalid");
6990 nghttp2_session_consume(session, iframe->frame.hd.stream_id, readlen);
7000 stream = nghttp2_session_get_stream(session, iframe->frame.hd.stream_id);
7029 stream = nghttp2_session_get_stream(session, iframe->frame.hd.stream_id);
7079 rv = nghttp2_session_consume(session, iframe->frame.hd.stream_id,
7111 session, iframe->frame.hd.stream_id, NGHTTP2_PROTOCOL_ERROR);
7122 session, iframe->frame.hd.flags, iframe->frame.hd.stream_id,
7484 int32_t stream_id,
7501 nghttp2_frame_window_update_init(&frame->window_update, flags, stream_id,
7668 session, frame->hd.type, stream->stream_id, session->remote_window_size,
7710 session, frame->hd.stream_id, buf->pos, datamax, &data_flags,
7786 int32_t stream_id) {
7788 stream = nghttp2_session_get_stream(session, stream_id);
7797 int32_t stream_id,
7803 stream = nghttp2_session_get_stream(session, stream_id);
7809 if (session->server || !nghttp2_session_is_my_stream_id(session, stream_id) ||
7817 if (frame->hd.stream_id > stream_id ||
7818 (uint32_t)stream_id >= session->next_stream_id) {
7823 if (item->frame.hd.stream_id < stream_id) {
7827 if (item->frame.hd.stream_id > stream_id) {
7838 int nghttp2_session_resume_data(nghttp2_session *session, int32_t stream_id) {
7841 stream = nghttp2_session_get_stream(session, stream_id);
7865 int32_t stream_id) {
7867 stream = nghttp2_session_get_stream(session, stream_id);
7876 int32_t stream_id) {
7878 stream = nghttp2_session_get_stream(session, stream_id);
7886 int32_t stream_id) {
7889 stream = nghttp2_session_get_stream(session, stream_id);
7920 int32_t stream_id) {
7923 stream = nghttp2_session_get_stream(session, stream_id);
8110 int32_t stream_id) {
8113 stream = nghttp2_session_get_stream(session, stream_id);
8123 int32_t stream_id) {
8126 stream = nghttp2_session_get_stream(session, stream_id);
8135 int nghttp2_session_consume(nghttp2_session *session, int32_t stream_id,
8140 if (stream_id == 0) {
8154 stream = nghttp2_session_get_stream(session, stream_id);
8185 int nghttp2_session_consume_stream(nghttp2_session *session, int32_t stream_id,
8190 if (stream_id == 0) {
8198 stream = nghttp2_session_get_stream(session, stream_id);
8241 int32_t stream_id) {
8242 if (stream_id == 0) {
8246 return nghttp2_session_get_stream_raw(session, stream_id);
8258 nghttp2_session *session, int32_t stream_id,
8268 if (stream_id == 0 || stream_id == pri_spec->stream_id) {
8272 stream = nghttp2_session_get_stream_raw(session, stream_id);
8295 int32_t stream_id,
8304 if (stream_id == 0 || stream_id == pri_spec->stream_id ||
8305 !session_detect_idle_stream(session, stream_id)) {
8309 stream = nghttp2_session_get_stream_raw(session, stream_id);
8318 nghttp2_session_open_stream(session, stream_id, NGHTTP2_STREAM_FLAG_NONE,
8347 nghttp2_session *session, int32_t stream_id,
8360 if (stream_id == 0) {
8364 stream = nghttp2_session_get_stream_raw(session, stream_id);