1#ifndef HEADER_CURL_VQUIC_QUIC_INT_H
2#define HEADER_CURL_VQUIC_QUIC_INT_H
3/***************************************************************************
4 * _ _ ____ _
5 * Project ___| | | | _ \| |
6 * / __| | | | |_) | |
7 * | (__| |_| | _ <| |___
8 * \___|\___/|_| \_\_____|
9 *
10 * Copyright (C) Daniel Stenberg, <daniel@haxx.se>, et al.
11 *
12 * This software is licensed as described in the file COPYING, which
13 * you should have received as part of this distribution. The terms
14 * are also available at https://curl.se/docs/copyright.html.
15 *
16 * You may opt to use, copy, modify, merge, publish, distribute and/or sell
17 * copies of the Software, and permit persons to whom the Software is
18 * furnished to do so, under the terms of the COPYING file.
19 *
20 * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY
21 * KIND, either express or implied.
22 *
23 * SPDX-License-Identifier: curl
24 *
25 ***************************************************************************/
26
27#include "curl_setup.h"
28#include "bufq.h"
29
30#ifdef ENABLE_QUIC
31
32#define MAX_PKT_BURST 10
33#define MAX_UDP_PAYLOAD_SIZE 1452
34
35struct cf_quic_ctx {
36 curl_socket_t sockfd; /* connected UDP socket */
37 struct sockaddr_storage local_addr; /* address socket is bound to */
38 socklen_t local_addrlen; /* length of local address */
39
40 struct bufq sendbuf; /* buffer for sending one or more packets */
41 size_t gsolen; /* length of individual packets in send buf */
42 size_t split_len; /* if != 0, buffer length after which GSO differs */
43 size_t split_gsolen; /* length of individual packets after split_len */
44#ifdef DEBUGBUILD
45 int wblock_percent; /* percent of writes doing EAGAIN */
46#endif
47 bool no_gso; /* do not use gso on sending */
48};
49
50CURLcode vquic_ctx_init(struct cf_quic_ctx *qctx);
51void vquic_ctx_free(struct cf_quic_ctx *qctx);
52
53void vquic_push_blocked_pkt(struct Curl_cfilter *cf,
54 struct cf_quic_ctx *qctx,
55 const uint8_t *pkt, size_t pktlen, size_t gsolen);
56
57CURLcode vquic_send_blocked_pkts(struct Curl_cfilter *cf,
58 struct Curl_easy *data,
59 struct cf_quic_ctx *qctx);
60
61CURLcode vquic_send(struct Curl_cfilter *cf, struct Curl_easy *data,
62 struct cf_quic_ctx *qctx, size_t gsolen);
63
64CURLcode vquic_send_tail_split(struct Curl_cfilter *cf, struct Curl_easy *data,
65 struct cf_quic_ctx *qctx, size_t gsolen,
66 size_t tail_len, size_t tail_gsolen);
67
68CURLcode vquic_flush(struct Curl_cfilter *cf, struct Curl_easy *data,
69 struct cf_quic_ctx *qctx);
70
71
72typedef CURLcode vquic_recv_pkt_cb(const unsigned char *pkt, size_t pktlen,
73 struct sockaddr_storage *remote_addr,
74 socklen_t remote_addrlen, int ecn,
75 void *userp);
76
77CURLcode vquic_recv_packets(struct Curl_cfilter *cf,
78 struct Curl_easy *data,
79 struct cf_quic_ctx *qctx,
80 size_t max_pkts,
81 vquic_recv_pkt_cb *recv_cb, void *userp);
82
83#endif /* !ENABLE_QUIC */
84
85#endif /* HEADER_CURL_VQUIC_QUIC_INT_H */
86