Lines Matching defs:stream_id
55 auto stream_id = submit_request_internal();
56 if (stream_id < 0) {
57 if (stream_id == NGTCP2_ERR_STREAM_ID_BLOCKED) {
68 nghttp3_ssize read_data(nghttp3_conn *conn, int64_t stream_id, nghttp3_vec *vec,
92 int64_t stream_id;
97 rv = ngtcp2_conn_open_bidi_stream(client_->quic.conn, &stream_id, nullptr);
106 conn_, stream_id, reinterpret_cast<nghttp3_nv *>(nva.data()), nva.size(),
112 client_->on_request(stream_id);
113 auto req_stat = client_->get_req_stat(stream_id);
117 return stream_id;
131 int stream_close(nghttp3_conn *conn, int64_t stream_id, uint64_t app_error_code,
134 if (s->stream_close(stream_id, app_error_code) != 0) {
141 int Http3Session::stream_close(int64_t stream_id, uint64_t app_error_code) {
142 if (!ngtcp2_is_bidi_stream(stream_id)) {
143 assert(!ngtcp2_conn_is_local_stream(client_->quic.conn, stream_id));
146 client_->on_stream_close(stream_id, app_error_code == NGHTTP3_H3_NO_ERROR);
151 int recv_data(nghttp3_conn *conn, int64_t stream_id, const uint8_t *data,
154 s->recv_data(stream_id, data, datalen);
159 void Http3Session::recv_data(int64_t stream_id, const uint8_t *data,
163 consume(stream_id, datalen);
167 int deferred_consume(nghttp3_conn *conn, int64_t stream_id, size_t nconsumed,
170 s->consume(stream_id, nconsumed);
175 void Http3Session::consume(int64_t stream_id, size_t nconsumed) {
176 ngtcp2_conn_extend_max_stream_offset(client_->quic.conn, stream_id,
182 int begin_headers(nghttp3_conn *conn, int64_t stream_id, void *user_data,
185 s->begin_headers(stream_id);
190 void Http3Session::begin_headers(int64_t stream_id) {
191 auto payloadlen = nghttp3_conn_get_frame_payload_left(conn_, stream_id);
198 int recv_header(nghttp3_conn *conn, int64_t stream_id, int32_t token,
204 s->recv_header(stream_id, &k, &v);
209 void Http3Session::recv_header(int64_t stream_id, const nghttp3_vec *name,
211 client_->on_header(stream_id, name->base, name->len, value->base, value->len);
216 int stop_sending(nghttp3_conn *conn, int64_t stream_id, uint64_t app_error_code,
219 if (s->stop_sending(stream_id, app_error_code) != 0) {
226 int Http3Session::stop_sending(int64_t stream_id, uint64_t app_error_code) {
227 auto rv = ngtcp2_conn_shutdown_stream_read(client_->quic.conn, 0, stream_id,
238 int reset_stream(nghttp3_conn *conn, int64_t stream_id, uint64_t app_error_code,
241 if (s->reset_stream(stream_id, app_error_code) != 0) {
248 int Http3Session::reset_stream(int64_t stream_id, uint64_t app_error_code) {
249 auto rv = ngtcp2_conn_shutdown_stream_write(client_->quic.conn, 0, stream_id,
259 int Http3Session::close_stream(int64_t stream_id, uint64_t app_error_code) {
260 auto rv = nghttp3_conn_close_stream(conn_, stream_id, app_error_code);
265 if (!ngtcp2_is_bidi_stream(stream_id)) {
266 assert(!ngtcp2_conn_is_local_stream(client_->quic.conn, stream_id));
275 int Http3Session::shutdown_stream_read(int64_t stream_id) {
276 auto rv = nghttp3_conn_shutdown_stream_read(conn_, stream_id);
287 auto stream_id = submit_request_internal();
288 if (stream_id < 0) {
289 if (stream_id == NGTCP2_ERR_STREAM_ID_BLOCKED) {
391 ssize_t Http3Session::read_stream(uint32_t flags, int64_t stream_id,
394 conn_, stream_id, data, datalen, flags & NGTCP2_STREAM_DATA_FLAG_FIN);
406 ssize_t Http3Session::write_stream(int64_t &stream_id, int &fin,
409 nghttp3_conn_writev_stream(conn_, &stream_id, &fin, vec, veccnt);
419 void Http3Session::block_stream(int64_t stream_id) {
420 nghttp3_conn_block_stream(conn_, stream_id);
423 int Http3Session::unblock_stream(int64_t stream_id) {
424 if (nghttp3_conn_unblock_stream(conn_, stream_id) != 0) {
431 void Http3Session::shutdown_stream_write(int64_t stream_id) {
432 nghttp3_conn_shutdown_stream_write(conn_, stream_id);
435 int Http3Session::add_write_offset(int64_t stream_id, size_t ndatalen) {
436 auto rv = nghttp3_conn_add_write_offset(conn_, stream_id, ndatalen);
446 int Http3Session::add_ack_offset(int64_t stream_id, size_t datalen) {
447 auto rv = nghttp3_conn_add_ack_offset(conn_, stream_id, datalen);