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);
841 assert(pri_spec->stream_id != stream->stream_id);
847 if (pri_spec->stream_id != 0) {
848 dep_stream = nghttp2_session_get_stream_raw(session, pri_spec->stream_id);
851 session_detect_idle_stream(session, pri_spec->stream_id)) {
856 session, pri_spec->stream_id, NGHTTP2_FLAG_NONE, &pri_spec_default,
868 if (pri_spec->stream_id == 0) {
872 dep_stream, dep_stream->stream_id, stream, stream->stream_id);
1113 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
1172 nghttp2_priority_spec_init(&pri_spec, stream->stream_id,
1183 here, since stream->stream_id is local stream_id, and it does
1194 } else if (frame->hd.stream_id == 0) {
1207 int nghttp2_session_add_rst_stream(nghttp2_session *session, int32_t stream_id,
1216 stream = nghttp2_session_get_stream(session, stream_id);
1225 if (nghttp2_session_is_my_stream_id(session, stream_id)) {
1226 if ((uint32_t)stream_id >= session->next_stream_id) {
1229 } else if (session->last_recv_stream_id < stream_id) {
1235 if (!session->server && nghttp2_session_is_my_stream_id(session, stream_id) &&
1243 if (headers_frame->hd.stream_id <= stream_id) {
1248 if (item->frame.hd.stream_id < stream_id) {
1252 /* stream_id in ob_syn queue must be strictly increasing. If
1254 if (item->frame.hd.stream_id > stream_id || aux_data->canceled) {
1275 nghttp2_frame_rst_stream_init(&frame->rst_stream, stream_id, error_code);
1286 int32_t stream_id, uint8_t flags,
1299 stream = nghttp2_session_get_stream_raw(session, stream_id);
1346 } else if (pri_spec->stream_id != 0) {
1347 dep_stream = nghttp2_session_get_stream_raw(session, pri_spec->stream_id);
1350 session_detect_idle_stream(session, pri_spec->stream_id)) {
1356 session, pri_spec->stream_id, NGHTTP2_FLAG_NONE, &pri_spec_default,
1369 pri_spec->stream_id == stream_id. This happens because we
1370 don't check pri_spec->stream_id against new stream ID in
1386 nghttp2_stream_init(stream, stream_id, flags, initial_state,
1396 rv = nghttp2_map_insert(&session->streams, stream_id, stream);
1411 if (nghttp2_session_is_my_stream_id(session, stream_id)) {
1428 if (nghttp2_session_is_my_stream_id(session, stream_id)) {
1439 if (pri_spec->stream_id == 0) {
1457 int nghttp2_session_close_stream(nghttp2_session *session, int32_t stream_id,
1465 stream = nghttp2_session_get_stream(session, stream_id);
1471 DEBUGF("stream: stream(%p)=%d close\n", stream, stream->stream_id);
1499 session, stream_id, error_code, session->user_data) != 0) {
1505 is_my_stream_id = nghttp2_session_is_my_stream_id(session, stream_id);
1550 DEBUGF("stream: destroy closed stream(%p)=%d\n", stream, stream->stream_id);
1561 nghttp2_map_remove(&session->streams, stream->stream_id);
1571 stream->stream_id, stream->state);
1587 stream->stream_id, stream->state);
1605 stream->stream_id, stream->state);
1722 * Closes stream with stream ID |stream_id| if both transmission and
1737 return nghttp2_session_close_stream(session, stream->stream_id,
1803 * frame->hd.stream_id.
1857 if (nghttp2_session_is_my_stream_id(session, stream->stream_id)) {
1951 if (nghttp2_session_is_my_stream_id(session, stream->stream_id)) {
2011 * This function checks WINDOW_UPDATE with the stream ID |stream_id|
2028 int32_t stream_id) {
2035 if (stream_id == 0) {
2039 stream = nghttp2_session_get_stream(session, stream_id);
2053 int32_t stream_id) {
2060 if (stream_id == 0) {
2064 stream = nghttp2_session_get_stream(session, stream_id);
2083 int32_t stream_id) {
2090 stream = nghttp2_session_get_stream(session, stream_id);
2113 stream->stream_id, stream->remote_window_size);
2166 if (nghttp2_session_is_my_stream_id(session, stream->stream_id)) {
2313 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
2324 stream = nghttp2_session_get_stream_raw(session, frame->hd.stream_id);
2366 rv = nghttp2_session_add_rst_stream(session, frame->hd.stream_id,
2391 session, frame->hd.stream_id, NGHTTP2_STREAM_FLAG_NONE,
2413 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
2467 assert(session->last_sent_stream_id < frame->hd.stream_id);
2468 session->last_sent_stream_id = frame->hd.stream_id;
2518 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
2572 rv = session_predicate_window_update_send(session, frame->hd.stream_id);
2600 rv = session_predicate_altsvc_send(session, frame->hd.stream_id);
2623 priority_update->stream_id);
2747 if (nghttp2_session_is_my_stream_id(arg->session, stream->stream_id)) {
2757 stream->stream_id > arg->last_stream_id) {
2793 rv = nghttp2_session_close_stream(session, stream->stream_id,
2866 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
2935 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
2955 frame->hd.stream_id, &aux_data->data_prd);
2983 frame->hd.stream_id, &aux_data->data_prd);
3002 stream = nghttp2_session_get_stream_raw(session, frame->hd.stream_id);
3005 if (!session_detect_idle_stream(session, frame->hd.stream_id)) {
3010 session, frame->hd.stream_id, NGHTTP2_FLAG_NONE,
3031 rv = nghttp2_session_close_stream(session, frame->hd.stream_id,
3061 if (frame->hd.stream_id == 0) {
3076 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
3159 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
3276 opened_stream_id = item->frame.hd.stream_id;
3326 "stream_id=%d\n",
3328 frame->hd.stream_id);
3351 opened_stream_id = item->frame.hd.stream_id;
3439 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
3456 rv = nghttp2_session_add_rst_stream(session, frame->hd.stream_id,
3615 DEBUGF("recv: call on_begin_headers callback stream_id=%d\n",
3616 frame->hd.stream_id);
3777 int32_t stream_id,
3782 session, stream_id, get_error_code_from_lib_error_code(lib_error_code));
3798 return session_handle_invalid_stream2(session, frame->hd.stream_id, frame,
3882 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
3907 session, subject_stream->stream_id, NGHTTP2_COMPRESSION_ERROR);
3949 frame->hd.type, frame->hd.stream_id, (int)nv.name->len,
3956 frame->hd.type, frame->hd.stream_id, (int)nv.name->len,
3967 frame->hd.type, frame->hd.stream_id, (int)nv.name->len,
3974 frame->hd.type, frame->hd.stream_id, (int)nv.name->len,
3982 subject_stream->stream_id,
4061 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
4101 int32_t stream_id;
4104 stream_id = frame->push_promise.promised_stream_id;
4106 stream_id = frame->hd.stream_id;
4109 rv = session_handle_invalid_stream2(session, stream_id, frame,
4141 if (frame->hd.stream_id == 0) {
4143 session, frame, NGHTTP2_ERR_PROTO, "request HEADERS: stream_id == 0");
4150 if (session_detect_idle_stream(session, frame->hd.stream_id)) {
4161 if (!session_is_new_peer_stream_id(session, frame->hd.stream_id)) {
4162 if (frame->hd.stream_id == 0 ||
4163 nghttp2_session_is_my_stream_id(session, frame->hd.stream_id)) {
4166 "request HEADERS: invalid stream_id");
4189 stream = nghttp2_session_get_stream_raw(session, frame->hd.stream_id);
4197 session->last_recv_stream_id = frame->hd.stream_id;
4210 if (frame->headers.pri_spec.stream_id == frame->hd.stream_id) {
4221 session, frame->hd.stream_id, NGHTTP2_STREAM_FLAG_NONE,
4246 NGHTTP2_STREAM_OPENING and stream_id is local side initiated. */
4248 nghttp2_session_is_my_stream_id(session, frame->hd.stream_id));
4249 if (frame->hd.stream_id == 0) {
4251 session, frame, NGHTTP2_ERR_PROTO, "response HEADERS: stream_id == 0");
4278 if (frame->hd.stream_id == 0) {
4281 "push response HEADERS: stream_id == 0");
4307 if (!nghttp2_session_is_my_stream_id(session, stream->stream_id)) {
4322 if (frame->hd.stream_id == 0) {
4324 session, frame, NGHTTP2_ERR_PROTO, "HEADERS: stream_id == 0");
4338 if (nghttp2_session_is_my_stream_id(session, frame->hd.stream_id)) {
4370 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
4383 nghttp2_session_is_my_stream_id(session, frame->hd.stream_id)) {
4399 if (frame->hd.stream_id == 0) {
4401 "PRIORITY: stream_id == 0");
4404 if (frame->priority.pri_spec.stream_id == frame->hd.stream_id) {
4414 stream = nghttp2_session_get_stream_raw(session, frame->hd.stream_id);
4419 if (!session_detect_idle_stream(session, frame->hd.stream_id)) {
4424 session, frame->hd.stream_id, NGHTTP2_STREAM_FLAG_NONE,
4484 if (frame->hd.stream_id == 0) {
4486 "RST_STREAM: stream_id == 0");
4489 if (session_detect_idle_stream(session, frame->hd.stream_id)) {
4494 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
4504 rv = nghttp2_session_close_stream(session, frame->hd.stream_id,
4533 return nghttp2_session_add_rst_stream(arg->session, stream->stream_id,
4584 return nghttp2_session_add_rst_stream(arg->session, stream->stream_id,
4600 stream->stream_id,
4735 if (frame->hd.stream_id != 0) {
4737 "SETTINGS: stream_id != 0");
4970 if (frame->hd.stream_id == 0) {
4972 session, frame, NGHTTP2_ERR_PROTO, "PUSH_PROMISE: stream_id == 0");
4979 if (!nghttp2_session_is_my_stream_id(session, frame->hd.stream_id)) {
4981 session, frame, NGHTTP2_ERR_PROTO, "PUSH_PROMISE: invalid stream_id");
4999 if (session_detect_idle_stream(session, frame->hd.stream_id)) {
5005 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
5027 nghttp2_priority_spec_init(&pri_spec, stream->stream_id,
5062 if (frame->hd.stream_id != 0) {
5064 "PING: stream_id != 0");
5092 if (frame->hd.stream_id != 0) {
5094 "GOAWAY: stream_id != 0");
5158 if (session_detect_idle_stream(session, frame->hd.stream_id)) {
5163 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
5198 if (frame->hd.stream_id == 0) {
5224 if (frame->hd.stream_id == 0) {
5235 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
5270 if (frame->hd.stream_id != 0) {
5272 "PRIORITY_UPDATE: stream_id == 0");
5275 if (nghttp2_session_is_my_stream_id(session, priority_update->stream_id)) {
5276 if (session_detect_idle_stream(session, priority_update->stream_id)) {
5286 stream = nghttp2_session_get_stream_raw(session, priority_update->stream_id);
5292 } else if (session_detect_idle_stream(session, priority_update->stream_id)) {
5301 stream = nghttp2_session_open_stream(session, priority_update->stream_id,
5401 stream = nghttp2_session_get_stream(session, frame->hd.stream_id);
5412 rv = nghttp2_session_add_rst_stream(session, stream->stream_id,
5479 return nghttp2_session_add_rst_stream(session, stream->stream_id,
5492 stream->stream_id,
5533 int32_t stream_id, size_t delta_size,
5553 stream_id, recv_size);
5572 stream->window_update_queued, stream->stream_id, delta_size,
5585 * indicated by |session->iframe.frame.hd.stream_id|. If it is a
5604 int32_t stream_id;
5609 stream_id = iframe->frame.hd.stream_id;
5611 if (stream_id == 0) {
5615 failure_reason = "DATA: stream_id == 0";
5619 if (session_detect_idle_stream(session, stream_id)) {
5625 stream = nghttp2_session_get_stream(session, stream_id);
5627 stream = nghttp2_session_get_stream_raw(session, stream_id);
5642 if (nghttp2_session_is_my_stream_id(session, stream_id)) {
5917 DEBUGF("recv: payloadlen=%zu, type=%u, flags=0x%02x, stream_id=%d\n",
5919 iframe->frame.hd.flags, iframe->frame.hd.stream_id);
5950 DEBUGF("recv: DATA not allowed stream_id=%d\n",
5951 iframe->frame.hd.stream_id);
6044 session, iframe->frame.hd.stream_id, NGHTTP2_INTERNAL_ERROR);
6303 if (session->server || iframe->frame.hd.stream_id ||
6459 session, iframe->frame.hd.stream_id, NGHTTP2_INTERNAL_ERROR);
6730 : iframe->frame.hd.stream_id,
6912 DEBUGF("recv: payloadlen=%zu, type=%u, flags=0x%02x, stream_id=%d\n",
6913 cont_hd.length, cont_hd.type, cont_hd.flags, cont_hd.stream_id);
6916 cont_hd.stream_id != iframe->frame.hd.stream_id) {
6917 DEBUGF("recv: expected stream_id=%d, type=%d, but got stream_id=%d, "
6919 iframe->frame.hd.stream_id, NGHTTP2_CONTINUATION,
6920 cont_hd.stream_id, cont_hd.type);
6923 "unexpected non-CONTINUATION frame or stream_id is invalid");
6979 nghttp2_session_consume(session, iframe->frame.hd.stream_id, readlen);
6989 stream = nghttp2_session_get_stream(session, iframe->frame.hd.stream_id);
7018 stream = nghttp2_session_get_stream(session, iframe->frame.hd.stream_id);
7068 rv = nghttp2_session_consume(session, iframe->frame.hd.stream_id,
7100 session, iframe->frame.hd.stream_id, NGHTTP2_PROTOCOL_ERROR);
7111 session, iframe->frame.hd.flags, iframe->frame.hd.stream_id,
7473 int32_t stream_id,
7490 nghttp2_frame_window_update_init(&frame->window_update, flags, stream_id,
7657 session, frame->hd.type, stream->stream_id, session->remote_window_size,
7699 session, frame->hd.stream_id, buf->pos, datamax, &data_flags,
7775 int32_t stream_id) {
7777 stream = nghttp2_session_get_stream(session, stream_id);
7786 int32_t stream_id,
7792 stream = nghttp2_session_get_stream(session, stream_id);
7798 if (session->server || !nghttp2_session_is_my_stream_id(session, stream_id) ||
7806 if (frame->hd.stream_id > stream_id ||
7807 (uint32_t)stream_id >= session->next_stream_id) {
7812 if (item->frame.hd.stream_id < stream_id) {
7816 if (item->frame.hd.stream_id > stream_id) {
7827 int nghttp2_session_resume_data(nghttp2_session *session, int32_t stream_id) {
7830 stream = nghttp2_session_get_stream(session, stream_id);
7854 int32_t stream_id) {
7856 stream = nghttp2_session_get_stream(session, stream_id);
7865 int32_t stream_id) {
7867 stream = nghttp2_session_get_stream(session, stream_id);
7875 int32_t stream_id) {
7878 stream = nghttp2_session_get_stream(session, stream_id);
7909 int32_t stream_id) {
7912 stream = nghttp2_session_get_stream(session, stream_id);
8099 int32_t stream_id) {
8102 stream = nghttp2_session_get_stream(session, stream_id);
8112 int32_t stream_id) {
8115 stream = nghttp2_session_get_stream(session, stream_id);
8124 int nghttp2_session_consume(nghttp2_session *session, int32_t stream_id,
8129 if (stream_id == 0) {
8143 stream = nghttp2_session_get_stream(session, stream_id);
8174 int nghttp2_session_consume_stream(nghttp2_session *session, int32_t stream_id,
8179 if (stream_id == 0) {
8187 stream = nghttp2_session_get_stream(session, stream_id);
8230 int32_t stream_id) {
8231 if (stream_id == 0) {
8235 return nghttp2_session_get_stream_raw(session, stream_id);
8247 nghttp2_session *session, int32_t stream_id,
8257 if (stream_id == 0 || stream_id == pri_spec->stream_id) {
8261 stream = nghttp2_session_get_stream_raw(session, stream_id);
8284 int32_t stream_id,
8293 if (stream_id == 0 || stream_id == pri_spec->stream_id ||
8294 !session_detect_idle_stream(session, stream_id)) {
8298 stream = nghttp2_session_get_stream_raw(session, stream_id);
8307 nghttp2_session_open_stream(session, stream_id, NGHTTP2_STREAM_FLAG_NONE,
8336 nghttp2_session *session, int32_t stream_id,
8349 if (stream_id == 0) {
8353 stream = nghttp2_session_get_stream_raw(session, stream_id);