| /third_party/node/deps/ngtcp2/nghttp3/lib/ |
| H A D | nghttp3_conn.c | 175 size_t nconsumed) { in conn_call_deferred_consume()
178 if (nconsumed == 0 || !conn->callbacks.deferred_consume) { in conn_call_deferred_consume()
182 rv = conn->callbacks.deferred_consume(conn, stream->node.nid.id, nconsumed, in conn_call_deferred_consume()
542 nghttp3_ssize nconsumed = 0; in nghttp3_conn_read_uni() local
583 nconsumed = nghttp3_conn_read_control(conn, stream, src, srclen); in nghttp3_conn_read_uni()
589 nconsumed = nghttp3_conn_read_qpack_encoder(conn, src, srclen); in nghttp3_conn_read_uni()
595 nconsumed = nghttp3_conn_read_qpack_decoder(conn, src, srclen); in nghttp3_conn_read_uni()
598 nconsumed = (nghttp3_ssize)srclen; in nghttp3_conn_read_uni()
610 if (nconsumed < 0) { in nghttp3_conn_read_uni()
611 return nconsumed; in nghttp3_conn_read_uni()
173 conn_call_deferred_consume(nghttp3_conn *conn, nghttp3_stream *stream, size_t nconsumed) conn_call_deferred_consume() argument
629 size_t nconsumed = 0; nghttp3_conn_read_control() local
1057 nghttp3_ssize nconsumed; conn_process_blocked_stream_data() local
1111 nghttp3_ssize nconsumed = nghttp3_conn_read_qpack_encoder() local
1178 size_t nconsumed = 0; nghttp3_conn_read_bidi() local
[all...] |
| /third_party/nghttp2/src/ |
| H A D | h2load_http3_session.cc | 167 int deferred_consume(nghttp3_conn *conn, int64_t stream_id, size_t nconsumed, in deferred_consume() argument
170 s->consume(stream_id, nconsumed); in deferred_consume()
175 void Http3Session::consume(int64_t stream_id, size_t nconsumed) { in consume() argument
177 nconsumed); in consume()
178 ngtcp2_conn_extend_max_offset(client_->quic.conn, nconsumed); in consume()
393 auto nconsumed = nghttp3_conn_read_stream( in read_stream() local
395 if (nconsumed < 0) { in read_stream()
396 std::cerr << "nghttp3_conn_read_stream: " << nghttp3_strerror(nconsumed) in read_stream()
400 nghttp3_err_infer_quic_app_error_code(nconsumed), nullptr, 0); in read_stream()
403 return nconsumed; in read_stream()
[all...] |
| H A D | h2load_http3_session.h | 50 void consume(int64_t stream_id, size_t nconsumed);
|
| H A D | shrpx_http3_upstream.cc | 285 auto nconsumed = nghttp3_conn_read_stream( in recv_stream_data() local
287 if (nconsumed < 0) { in recv_stream_data()
289 << nghttp3_strerror(nconsumed); in recv_stream_data()
291 &last_error_, nghttp3_err_infer_quic_app_error_code(nconsumed), nullptr, in recv_stream_data()
296 ngtcp2_conn_extend_max_stream_offset(conn_, stream_id, nconsumed); in recv_stream_data()
297 ngtcp2_conn_extend_max_offset(conn_, nconsumed); in recv_stream_data()
2020 size_t nconsumed, void *user_data, in http_deferred_consume()
2024 upstream->consume(stream_id, nconsumed); in http_deferred_consume()
2772 void Http3Upstream::consume(int64_t stream_id, size_t nconsumed) { in consume() argument
2773 ngtcp2_conn_extend_max_stream_offset(conn_, stream_id, nconsumed); in consume()
2019 http_deferred_consume(nghttp3_conn *conn, int64_t stream_id, size_t nconsumed, void *user_data, void *stream_user_data) http_deferred_consume() argument
[all...] |
| H A D | h2load_quic.cc | 81 auto nconsumed = s->read_stream(flags, stream_id, data, datalen); in quic_recv_stream_data() local
82 if (nconsumed == -1) { in quic_recv_stream_data()
86 ngtcp2_conn_extend_max_stream_offset(quic.conn, stream_id, nconsumed); in quic_recv_stream_data()
87 ngtcp2_conn_extend_max_offset(quic.conn, nconsumed); in quic_recv_stream_data()
|
| H A D | shrpx_http3_upstream.h | 125 void consume(int64_t stream_id, size_t nconsumed);
|
| /third_party/curl/lib/vquic/ |
| H A D | curl_ngtcp2.c | 427 nghttp3_ssize nconsumed; in cb_recv_stream_data() local
433 nconsumed = in cb_recv_stream_data()
436 stream_id, buflen, nconsumed); in cb_recv_stream_data()
437 if(nconsumed < 0) { in cb_recv_stream_data()
446 nghttp3_err_infer_quic_app_error_code((int)nconsumed), NULL, 0); in cb_recv_stream_data()
453 ngtcp2_conn_extend_max_stream_offset(tconn, stream_id, nconsumed); in cb_recv_stream_data()
454 ngtcp2_conn_extend_max_offset(tconn, nconsumed); in cb_recv_stream_data()
|