Lines Matching defs:stream_id
246 void Http3Upstream::http_begin_request_headers(int64_t stream_id) {
248 std::make_unique<Downstream>(this, handler_->get_mcpool(), stream_id);
249 nghttp3_conn_set_stream_user_data(httpconn_, stream_id, downstream.get());
268 int recv_stream_data(ngtcp2_conn *conn, uint32_t flags, int64_t stream_id,
273 if (upstream->recv_stream_data(flags, stream_id, data, datalen) != 0) {
281 int Http3Upstream::recv_stream_data(uint32_t flags, int64_t stream_id,
286 httpconn_, stream_id, data, datalen, flags & NGTCP2_STREAM_DATA_FLAG_FIN);
296 ngtcp2_conn_extend_max_stream_offset(conn_, stream_id, nconsumed);
303 int stream_close(ngtcp2_conn *conn, uint32_t flags, int64_t stream_id,
312 if (upstream->stream_close(stream_id, app_error_code) != 0) {
320 int Http3Upstream::stream_close(int64_t stream_id, uint64_t app_error_code) {
325 auto rv = nghttp3_conn_close_stream(httpconn_, stream_id, app_error_code);
330 if (ngtcp2_is_bidi_stream(stream_id)) {
345 int acked_stream_data_offset(ngtcp2_conn *conn, int64_t stream_id,
350 if (upstream->acked_stream_data_offset(stream_id, datalen) != 0) {
358 int Http3Upstream::acked_stream_data_offset(int64_t stream_id,
364 auto rv = nghttp3_conn_add_ack_offset(httpconn_, stream_id, datalen);
375 int extend_max_stream_data(ngtcp2_conn *conn, int64_t stream_id,
380 if (upstream->extend_max_stream_data(stream_id) != 0) {
388 int Http3Upstream::extend_max_stream_data(int64_t stream_id) {
393 auto rv = nghttp3_conn_unblock_stream(httpconn_, stream_id);
419 int stream_reset(ngtcp2_conn *conn, int64_t stream_id, uint64_t final_size,
424 if (upstream->stream_reset(stream_id) != 0) {
432 int Http3Upstream::stream_reset(int64_t stream_id) {
433 if (http_shutdown_stream_read(stream_id) != 0) {
437 if (ngtcp2_is_bidi_stream(stream_id)) {
438 auto rv = ngtcp2_conn_shutdown_stream_write(conn_, 0, stream_id,
450 int Http3Upstream::http_shutdown_stream_read(int64_t stream_id) {
455 auto rv = nghttp3_conn_shutdown_stream_read(httpconn_, stream_id);
466 int stream_stop_sending(ngtcp2_conn *conn, int64_t stream_id,
471 if (upstream->http_shutdown_stream_read(stream_id) != 0) {
816 int64_t stream_id = -1;
821 sveccnt = nghttp3_conn_writev_stream(httpconn_, &stream_id, &fin,
844 stream_id, reinterpret_cast<const ngtcp2_vec *>(v), vcnt, ts);
849 nghttp3_conn_block_stream(httpconn_, stream_id);
853 nghttp3_conn_shutdown_stream_write(httpconn_, stream_id);
857 rv = nghttp3_conn_add_write_offset(httpconn_, stream_id, ndatalen);
878 rv = nghttp3_conn_add_write_offset(httpconn_, stream_id, ndatalen);
1128 DCLOG(INFO, dconn) << "EOF. stream_id=" << downstream->get_stream_id();
1226 int64_t stream_id, nghttp3_vec *vec,
1259 upstream->shutdown_stream_read(stream_id, NGHTTP3_H3_NO_ERROR) != 0) {
2019 int http_deferred_consume(nghttp3_conn *conn, int64_t stream_id,
2024 upstream->consume(stream_id, nconsumed);
2031 int http_acked_stream_data(nghttp3_conn *conn, int64_t stream_id,
2068 int http_begin_request_headers(nghttp3_conn *conn, int64_t stream_id,
2070 if (!ngtcp2_is_bidi_stream(stream_id)) {
2075 upstream->http_begin_request_headers(stream_id);
2082 int http_recv_request_header(nghttp3_conn *conn, int64_t stream_id,
2103 int http_recv_request_trailer(nghttp3_conn *conn, int64_t stream_id,
2181 int http_end_request_headers(nghttp3_conn *conn, int64_t stream_id, int fin,
2223 ULOG(INFO, this) << "HTTP request headers. stream_id="
2424 int http_recv_data(nghttp3_conn *conn, int64_t stream_id, const uint8_t *data,
2455 int http_end_stream(nghttp3_conn *conn, int64_t stream_id, void *user_data,
2487 int http_stream_close(nghttp3_conn *conn, int64_t stream_id,
2507 auto stream_id = downstream->get_stream_id();
2510 ULOG(INFO, this) << "Stream stream_id=" << stream_id
2522 consume(stream_id, req.unconsumed_body_length);
2553 int http_stop_sending(nghttp3_conn *conn, int64_t stream_id,
2558 if (upstream->http_stop_sending(stream_id, app_error_code) != 0) {
2566 int Http3Upstream::http_stop_sending(int64_t stream_id,
2569 ngtcp2_conn_shutdown_stream_read(conn_, 0, stream_id, app_error_code);
2580 int http_reset_stream(nghttp3_conn *conn, int64_t stream_id,
2585 if (upstream->http_reset_stream(stream_id, app_error_code) != 0) {
2593 int Http3Upstream::http_reset_stream(int64_t stream_id,
2596 ngtcp2_conn_shutdown_stream_write(conn_, 0, stream_id, app_error_code);
2742 auto stream_id = downstream->get_stream_id();
2745 ULOG(INFO, this) << "Shutdown stream_id=" << stream_id
2749 auto rv = ngtcp2_conn_shutdown_stream(conn_, 0, stream_id, app_error_code);
2759 int Http3Upstream::shutdown_stream_read(int64_t stream_id,
2761 auto rv = ngtcp2_conn_shutdown_stream_read(conn_, 0, stream_id,
2772 void Http3Upstream::consume(int64_t stream_id, size_t nconsumed) {
2773 ngtcp2_conn_extend_max_stream_offset(conn_, stream_id, nconsumed);
2804 ULOG(INFO, this) << "HTTP response headers. stream_id="