Lines Matching defs:stream_id
74 int32_t stream_id;
171 stream_id(-1),
306 anchor_id = anchors[ANCHOR_LEADERS].stream_id;
310 anchor_id = anchors[ANCHOR_UNBLOCKED].stream_id;
314 anchor_id = anchors[ANCHOR_FOLLOWERS].stream_id;
318 anchor_id = anchors[ANCHOR_FOLLOWERS].stream_id;
374 req->stream_id, req->data_prd);
380 req->stream_id, NGHTTP2_INTERNAL_ERROR);
521 int32_t stream_id;
524 stream_id = nghttp2_submit_headers(client->session, 0, -1, &req->pri_spec,
527 stream_id =
532 if (stream_id < 0) {
535 << "() returned error: " << nghttp2_strerror(stream_id)
540 req->stream_id = stream_id;
1178 stream_user_data->stream_id = 1;
1200 rv = nghttp2_submit_priority(session, NGHTTP2_FLAG_NONE, anchor.stream_id,
1208 session, anchors[ANCHOR_FOLLOWERS].stream_id + 2);
1217 nghttp2_priority_spec_init(&pri_spec, anchor.stream_id,
1501 if (req->stream_id % 2 == 0) {
1590 auto pushed = req->stream_id % 2 == 0;
1671 json_string(util::utos(req->stream_id).c_str()));
1732 int32_t stream_id, const uint8_t *data,
1736 nghttp2_session_get_stream_user_data(session, stream_id));
1743 verbose_on_data_chunk_recv_callback(session, flags, stream_id, data, len,
1758 nghttp2_submit_rst_stream(session, NGHTTP2_FLAG_NONE, stream_id,
1802 nghttp2_submit_rst_stream(session, NGHTTP2_FLAG_NONE, req->stream_id,
1809 nghttp2_submit_rst_stream(session, NGHTTP2_FLAG_NONE, req->stream_id,
1860 nghttp2_session_get_stream_user_data(session, frame->hd.stream_id));
1877 auto stream_id = frame->push_promise.promised_stream_id;
1885 req->stream_id = stream_id;
1887 nghttp2_session_set_stream_user_data(session, stream_id, req.get());
1913 nghttp2_session_get_stream_user_data(session, frame->hd.stream_id));
1926 nghttp2_submit_rst_stream(session, NGHTTP2_FLAG_NONE, frame->hd.stream_id,
1982 nghttp2_session_get_stream_user_data(session, frame->hd.stream_id));
1997 nghttp2_session_get_stream_user_data(session, frame->hd.stream_id));
2017 frame->hd.stream_id, NGHTTP2_PROTOCOL_ERROR);
2104 nghttp2_session_get_stream_user_data(session, frame->hd.stream_id));
2125 nghttp2_session_get_stream_user_data(session, frame->hd.stream_id));
2149 nghttp2_session_get_stream_user_data(session, frame->hd.stream_id));
2162 int on_stream_close_callback(nghttp2_session *session, int32_t stream_id,
2166 nghttp2_session_get_stream_user_data(session, stream_id));
2241 auto pushed = req->stream_id % 2 == 0;
2243 std::cout << std::setw(3) << req->stream_id << " " << std::setw(11)
2368 dep_stream_id = anchors[ANCHOR_FOLLOWERS].stream_id;
2441 ssize_t file_read_callback(nghttp2_session *session, int32_t stream_id,
2446 nghttp2_session_get_stream_user_data(session, stream_id));
2469 rv = nghttp2_submit_trailer(session, stream_id, nva.data(), nva.size());