Searched refs:ndatalen (Results 1 - 7 of 7) sorted by relevance
| /third_party/nghttp2/src/ |
| H A D | h2load_quic.cc | 679 ngtcp2_ssize ndatalen; in write_quic() local
689 quic.conn, &ps.path, nullptr, bufpos, max_udp_payload_size, &ndatalen, in write_quic()
694 assert(ndatalen == -1); in write_quic()
698 assert(ndatalen == -1); in write_quic()
702 assert(ndatalen >= 0); in write_quic()
703 if (s->add_write_offset(stream_id, ndatalen) != 0) { in write_quic()
711 } else if (ndatalen >= 0 && s->add_write_offset(stream_id, ndatalen) != 0) { in write_quic()
|
| H A D | h2load_http3_session.h | 69 int add_write_offset(int64_t stream_id, size_t ndatalen);
|
| H A D | shrpx_http3_upstream.cc | 833 ngtcp2_ssize ndatalen; in write_streams() local
843 conn_, &ps.path, &pi, bufpos, max_udp_payload_size, &ndatalen, flags, in write_streams()
848 assert(ndatalen == -1); in write_streams()
852 assert(ndatalen == -1); in write_streams()
856 assert(ndatalen >= 0); in write_streams()
857 rv = nghttp3_conn_add_write_offset(httpconn_, stream_id, ndatalen); in write_streams()
869 assert(ndatalen == -1); in write_streams()
877 } else if (ndatalen >= 0) { in write_streams()
878 rv = nghttp3_conn_add_write_offset(httpconn_, stream_id, ndatalen); in write_streams()
|
| H A D | h2load_http3_session.cc | 435 int Http3Session::add_write_offset(int64_t stream_id, size_t ndatalen) { in add_write_offset() argument
436 auto rv = nghttp3_conn_add_write_offset(conn_, stream_id, ndatalen); in add_write_offset()
|
| /third_party/curl/lib/vquic/ |
| H A D | curl_ngtcp2.c | 1639 ngtcp2_ssize ndatalen; in read_pkt_to_send() local
1677 &ndatalen, flags, stream_id, in read_pkt_to_send()
1689 DEBUGASSERT(ndatalen == -1); in read_pkt_to_send()
1700 DEBUGASSERT(ndatalen == -1); in read_pkt_to_send()
1707 DEBUGASSERT(ndatalen >= 0); in read_pkt_to_send()
1711 DEBUGASSERT(ndatalen == -1); in read_pkt_to_send()
1721 if(ndatalen >= 0) { in read_pkt_to_send()
1723 int rv = nghttp3_conn_add_write_offset(ctx->h3conn, stream_id, ndatalen); in read_pkt_to_send()
|
| /third_party/node/deps/ngtcp2/ngtcp2/lib/ |
| H A D | ngtcp2_pkt.c | 561 size_t ndatalen = 0; in ngtcp2_pkt_decode_stream_frame() local
604 ndatalen = ngtcp2_get_varint_len(p); in ngtcp2_pkt_decode_stream_frame()
605 len += ndatalen - 1; in ngtcp2_pkt_decode_stream_frame()
611 vi = ngtcp2_get_varint(&ndatalen, p); in ngtcp2_pkt_decode_stream_frame()
637 p += ndatalen; in ngtcp2_pkt_decode_stream_frame()
1296 size_t ndatalen; in ngtcp2_pkt_decode_crypto_frame() local
1315 ndatalen = ngtcp2_get_varint_len(p); in ngtcp2_pkt_decode_crypto_frame()
1316 len += ndatalen - 1; in ngtcp2_pkt_decode_crypto_frame()
1322 vi = ngtcp2_get_varint(&ndatalen, p); in ngtcp2_pkt_decode_crypto_frame()
1336 p += ndatalen; in ngtcp2_pkt_decode_crypto_frame()
[all...] |
| H A D | ngtcp2_conn.c | 3480 uint64_t ndatalen = 0; in conn_write_pkt() local
3520 ndatalen = conn_enforce_flow_control(conn, vmsg->stream.strm, datalen); in conn_write_pkt()
3522 if (ndatalen || datalen == 0) { in conn_write_pkt()
4040 (ndatalen = ngtcp2_pkt_stream_max_datalen( in conn_write_pkt()
4041 vmsg->stream.strm->stream_id, vmsg->stream.strm->tx.offset, ndatalen, in conn_write_pkt()
4043 (ndatalen || datalen == 0)) { in conn_write_pkt()
4046 (size_t)ndatalen); in conn_write_pkt()
4047 ndatalen = ngtcp2_vec_len(data, datacnt); in conn_write_pkt()
4066 ndatalen == datalen; in conn_write_pkt()
4082 vmsg->stream.strm->tx.offset += ndatalen; in conn_write_pkt()
[all...] |
Completed in 20 milliseconds