Lines Matching refs:datalen
61 uint64_t offset, const uint8_t *data, size_t datalen,
64 if (c->quic_recv_stream_data(flags, stream_id, data, datalen) != 0) {
75 const uint8_t *data, size_t datalen) {
77 worker->stats.bytes_total += datalen;
81 auto nconsumed = s->read_stream(flags, stream_id, data, datalen);
94 uint64_t offset, uint64_t datalen, void *user_data,
97 if (c->quic_acked_stream_data_offset(stream_id, datalen) != 0) {
104 int Client::quic_acked_stream_data_offset(int64_t stream_id, size_t datalen) {
106 if (s->add_ack_offset(stream_id, datalen) != 0) {
228 cid->datalen = cidlen;
252 dest.datalen = 8;
254 if (RAND_bytes(dest.data, dest.datalen) != 1) {
273 size_t datalen) {
275 c->quic_write_qlog(data, datalen);
279 void Client::quic_write_qlog(const void *data, size_t datalen) {
281 fwrite(data, 1, datalen, quic.qlog_file);
492 const uint8_t *data, size_t datalen) {
497 rv = ngtcp2_conn_submit_crypto_data(quic.conn, level, data, datalen);
593 auto datalen = std::min(static_cast<size_t>(nread), gso_size);
597 rv = ngtcp2_conn_read_pkt(quic.conn, &path, &pi, data, datalen, ts);
612 nread -= datalen;
617 data += datalen;
720 auto datalen = bufpos - quic.tx.data.get();
722 datalen, gso_size);
724 on_send_blocked(ps.path.remote, data, datalen, gso_size);
738 auto datalen = bufpos - quic.tx.data.get();
739 rv = write_udp(ps.path.remote.addr, ps.path.remote.addrlen, data, datalen,
742 on_send_blocked(ps.path.remote, data, datalen, 0);
766 auto datalen = bufpos - quic.tx.data.get() - nwrite;
767 rv = write_udp(ps.path.remote.addr, ps.path.remote.addrlen, data, datalen,
770 on_send_blocked(ps.path.remote, data, datalen, gso_size);
788 auto datalen = bufpos - quic.tx.data.get();
789 rv = write_udp(ps.path.remote.addr, ps.path.remote.addrlen, data, datalen,
792 on_send_blocked(ps.path.remote, data, datalen, gso_size);
802 const uint8_t *data, size_t datalen,
815 p.datalen = datalen;
828 rv = write_udp(&p.remote_addr.su.sa, p.remote_addr.len, p.data, p.datalen,