Lines Matching refs:datalen
178 size_t datalen) {
181 upstream->qlog_write(data, datalen, flags & NGTCP2_QLOG_WRITE_FLAG_FIN);
185 void Http3Upstream::qlog_write(const void *data, size_t datalen, bool fin) {
188 while (write(qlog_fd_, data, datalen) == -1 && errno == EINTR)
269 uint64_t offset, const uint8_t *data, size_t datalen,
273 if (upstream->recv_stream_data(flags, stream_id, data, datalen) != 0) {
282 const uint8_t *data, size_t datalen) {
286 httpconn_, stream_id, data, datalen, flags & NGTCP2_STREAM_DATA_FLAG_FIN);
346 uint64_t offset, uint64_t datalen, void *user_data,
350 if (upstream->acked_stream_data_offset(stream_id, datalen) != 0) {
359 uint64_t datalen) {
364 auto rv = nghttp3_conn_add_ack_offset(httpconn_, stream_id, datalen);
893 auto datalen = bufpos - data;
897 prev_ps.path.local.addrlen, prev_pi, data, datalen,
901 prev_pi, data, datalen, gso_size);
926 auto datalen = bufpos - data - nwrite;
930 prev_ps.path.local.addrlen, prev_pi, data, datalen,
935 data, datalen, gso_size);
968 auto datalen = bufpos - data;
972 datalen, gso_size);
974 on_send_blocked(faddr, ps.path.remote, ps.path.local, pi, data, datalen,
987 auto datalen = bufpos - data;
991 datalen, 0);
993 on_send_blocked(faddr, ps.path.remote, ps.path.local, pi, data, datalen,
1786 const uint8_t *data, size_t datalen) {
1801 rv = ngtcp2_conn_read_pkt(conn_, &path, &pi, data, datalen, quic_timestamp());
1820 ngtcp2_pkt_decode_version_cid(&vc, data, datalen, SHRPX_QUIC_SCIDLEN);
1829 remote_addr, local_addr, datalen * 3);
1859 size_t datalen, size_t gso_size) {
1861 local_salen, pi, data, datalen, gso_size);
1887 const uint8_t *data, size_t datalen,
1904 p.datalen = datalen;
1918 p.datalen, p.gso_size);
2032 uint64_t datalen, void *user_data,
2039 if (upstream->http_acked_stream_data(downstream, datalen) != 0) {
2048 uint64_t datalen) {
2051 << datalen << " bytes acknowledged";
2055 auto drained = body->drain_mark(datalen);
2058 assert(datalen == drained);
2060 if (downstream->resume_read(SHRPX_NO_BUFFER, datalen) != 0) {
2425 size_t datalen, void *user_data, void *stream_user_data) {
2429 if (upstream->http_recv_data(downstream, data, datalen) != 0) {
2438 size_t datalen) {
2441 if (downstream->push_upload_data_chunk(data, datalen) != 0) {
2446 consume(downstream->get_stream_id(), datalen);
2873 path += util::format_hex(scid.data, scid.datalen);