2
0

vquic_int.h 3.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182
  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. #include "curl_setup.h"
  27. #include "bufq.h"
  28. #ifdef ENABLE_QUIC
  29. #define MAX_PKT_BURST 10
  30. #define MAX_UDP_PAYLOAD_SIZE 1452
  31. struct cf_quic_ctx {
  32. curl_socket_t sockfd; /* connected UDP socket */
  33. struct sockaddr_storage local_addr; /* address socket is bound to */
  34. socklen_t local_addrlen; /* length of local address */
  35. struct bufq sendbuf; /* buffer for sending one or more packets */
  36. size_t gsolen; /* length of individual packets in send buf */
  37. size_t split_len; /* if != 0, buffer length after which GSO differs */
  38. size_t split_gsolen; /* length of individual packets after split_len */
  39. bool no_gso; /* do not use gso on sending */
  40. };
  41. CURLcode vquic_ctx_init(struct cf_quic_ctx *qctx);
  42. void vquic_ctx_free(struct cf_quic_ctx *qctx);
  43. void vquic_push_blocked_pkt(struct Curl_cfilter *cf,
  44. struct cf_quic_ctx *qctx,
  45. const uint8_t *pkt, size_t pktlen, size_t gsolen);
  46. CURLcode vquic_send_blocked_pkts(struct Curl_cfilter *cf,
  47. struct Curl_easy *data,
  48. struct cf_quic_ctx *qctx);
  49. CURLcode vquic_send(struct Curl_cfilter *cf, struct Curl_easy *data,
  50. struct cf_quic_ctx *qctx, size_t gsolen);
  51. CURLcode vquic_send_tail_split(struct Curl_cfilter *cf, struct Curl_easy *data,
  52. struct cf_quic_ctx *qctx, size_t gsolen,
  53. size_t tail_len, size_t tail_gsolen);
  54. CURLcode vquic_flush(struct Curl_cfilter *cf, struct Curl_easy *data,
  55. struct cf_quic_ctx *qctx);
  56. typedef CURLcode vquic_recv_pkt_cb(const unsigned char *pkt, size_t pktlen,
  57. struct sockaddr_storage *remote_addr,
  58. socklen_t remote_addrlen, int ecn,
  59. void *userp);
  60. CURLcode vquic_recv_packets(struct Curl_cfilter *cf,
  61. struct Curl_easy *data,
  62. struct cf_quic_ctx *qctx,
  63. size_t max_pkts,
  64. vquic_recv_pkt_cb *recv_cb, void *userp);
  65. #endif /* !ENABLE_QUIC */
  66. #endif /* HEADER_CURL_VQUIC_QUIC_INT_H */