Lines Matching defs:stream_id
137 std::cout << " timeout stream_id=" << stream->stream_id << std::endl;
454 Stream::Stream(Http2Handler *handler, int32_t stream_id)
462 stream_id(stream_id),
960 return nghttp2_submit_response(session_, stream->stream_id, nva.data(), nvlen,
964 int Http2Handler::submit_response(const StringRef &status, int32_t stream_id,
983 int r = nghttp2_submit_response(session_, stream_id, nva.data(), nva.size(),
988 int Http2Handler::submit_response(const StringRef &status, int32_t stream_id,
1003 return nghttp2_submit_response(session_, stream_id, nva.data(), nvlen,
1008 int32_t stream_id) {
1010 return nghttp2_submit_headers(session_, NGHTTP2_FLAG_NONE, stream_id, nullptr,
1031 session_, NGHTTP2_FLAG_END_HEADERS, stream->stream_id, nva.data(),
1057 stream->stream_id, error_code);
1060 void Http2Handler::add_stream(int32_t stream_id,
1062 id2stream_[stream_id] = std::move(stream);
1065 void Http2Handler::remove_stream(int32_t stream_id) {
1066 id2stream_.erase(stream_id);
1069 Stream *Http2Handler::get_stream(int32_t stream_id) {
1070 auto itr = id2stream_.find(stream_id);
1094 ssize_t file_read_callback(nghttp2_session *session, int32_t stream_id,
1099 auto stream = hd->get_stream(stream_id);
1116 rv = nghttp2_submit_trailer(session, stream_id, nva.data(), nva.size());
1126 if (nghttp2_session_get_stream_remote_close(session, stream_id) == 0) {
1156 hd->submit_response(StringRef{status_page->status}, stream->stream_id,
1185 hd->submit_response(StringRef::from_lit("200"), stream->stream_id, headers,
1228 hd->submit_response(StringRef{status_page->status}, stream->stream_id,
1381 hd->submit_response(StringRef::from_lit("304"), stream->stream_id, nullptr);
1424 auto stream = hd->get_stream(frame->hd.stream_id);
1492 auto stream = std::make_unique<Stream>(hd, frame->hd.stream_id);
1496 hd->add_stream(frame->hd.stream_id, std::move(stream));
1513 auto stream = hd->get_stream(frame->hd.stream_id);
1530 auto stream = hd->get_stream(frame->hd.stream_id);
1540 hd->submit_non_final_response("100", frame->hd.stream_id);
1592 auto stream = hd->get_stream(frame->hd.stream_id);
1601 session, frame->hd.stream_id),
1625 auto stream = hd->get_stream(frame->hd.stream_id);
1648 auto stream = hd->get_stream(frame->hd.stream_id);
1704 int32_t stream_id, const uint8_t *data,
1707 auto stream = hd->get_stream(stream_id);
1737 int on_stream_close_callback(nghttp2_session *session, int32_t stream_id,
1740 hd->remove_stream(stream_id);
1744 printf(" stream_id=%d closed\n", stream_id);