srvxdp.h

Go to the documentation of this file.

#ifndef WIRED_SRVXDP_SRVXDP_H
#define WIRED_SRVXDP_SRVXDP_H
 
#include "app/http3/server/srvxdpbpf/srvxdpbpf.h"
#include "common/bytes/span/span.h"
#include "transport/io/socket/io/udp.h"
#include "transport/io/xdp/xdpmac/xdpmac.h"
#include "transport/io/xdp/xsksetup/xsksetup.h"
#include "transport/io/xdp/xskumem/xskumem.h"


typedef struct {
  u32 ifindex;      
  u32 queue_id;     
  u8  ip[4];        
  u16 port;         
  u16 bind_flags;   
  u32 attach_flags; 
} wired_srvxdp_cfg;

typedef struct {
  xsk           xsk;        
  xskumem_alloc txpool;     
  xdpmac        macs;       
  u8            our_mac[6]; 
  int           have_mac;   
  u32           ip_be;      
  u16           port;       
  wired_srvxdpbpf bpf;
  int bpf_owned;
} wired_srvxdp;

i64 wired_srvxdp_open(wired_srvxdp* x, const wired_srvxdp_cfg* cfg);

i64 wired_srvxdp_open_shared(
    wired_srvxdp* x, const wired_srvxdp_cfg* cfg, wired_srvxdpbpf* bpf);

i64 wired_srvxdp_rx_burst(wired_srvxdp* x, mmsg_buf* bufs, usz nbufs);

i64 wired_srvxdp_send(wired_srvxdp* x, const sockaddr* dst, wired_span pkt);

void wired_srvxdp_close(wired_srvxdp* x);

void wired_srvxdp_print_stats(i64 fd);
 
#endif