udp.h

Go to the documentation of this file.

#ifndef WIRED_IO_UDP_H
#define WIRED_IO_UDP_H
 
#include "common/bytes/span/span.h"
#include "common/platform/sys/syscall.h"


#define WIRED_AF_INET 2
#define WIRED_AF_INET6 10
#define WIRED_SOCK_DGRAM 2

typedef struct {
  u16 family;   
  u16 port_be;  
  u32 flowinfo; 
  u8  addr[16]; 
  u32 scope_id; 
} quic_sockaddr;

void wired_udp_addr(quic_sockaddr* sa, u16 port, const u8 octets[4]);

static inline u32 wired_udp_addr4_be(const quic_sockaddr* sa) {
  return ((u32)sa->addr[12] << 24) | ((u32)sa->addr[13] << 16) |
         ((u32)sa->addr[14] << 8) | sa->addr[15];
}

i64 wired_udp_socket(void);

i64 wired_udp_bind(i64 fd, const quic_sockaddr* sa);

i64 wired_udp_send(i64 fd, const quic_sockaddr* sa, quic_span buf);

i64 wired_udp_recv(i64 fd, quic_mspan buf);

i64 wired_udp_recvfrom(i64 fd, quic_mspan buf, quic_sockaddr* src);

i64 wired_udp_close(i64 fd);

#define WIRED_GSO_CMSG_SPACE 24

i64 wired_udp_gso_enable(i64 fd, u16 segsize);

void wired_udp_gso_cmsg_build(u8 out[WIRED_GSO_CMSG_SPACE], u16 segsize);

i64 wired_udp_send_gso(
    i64 fd, const quic_sockaddr* sa, quic_span buf, u16 segsize);

i64 wired_udp_send_batch(
    i64 fd, const quic_sockaddr* sa, quic_span buf, u16 segsize);

typedef struct {
  quic_mspan    buf; 
  quic_sockaddr src; 
  u32           len; 
  u8 ecn;
} quic_mmsg_buf;

i64 wired_udp_recvmmsg(i64 fd, quic_mmsg_buf* bufs, usz count);

i64 wired_udp_recvmmsg_fallback(i64 fd, quic_mmsg_buf* bufs, usz count);

i64 wired_udp_ect0_enable(i64 fd);

i64 wired_udp_pmtu_probe_enable(i64 fd);

i64 wired_udp_recvtos_enable(i64 fd);

i64 wired_udp_reuseport_enable(i64 fd);

i64 wired_udp_recvmmsg_nowait(i64 fd, quic_mmsg_buf* bufs, usz count);

i64 wired_udp_busy_poll_enable(i64 fd, int microseconds);

i64 wired_udp_prefer_busy_poll_enable(i64 fd, int enable);

i64 wired_udp_busy_poll_budget_set(i64 fd, int budget);

i64 wired_udp_incoming_cpu_set(i64 fd, int cpu);
 
#endif