srvboot.h

Go to the documentation of this file.

#ifndef WIRED_SRVBOOT_SRVBOOT_H
#define WIRED_SRVBOOT_SRVBOOT_H
 
#include "app/http3/server/srvloop/srvloop.h"
#include "common/bytes/span/span.h"
#include "tls/handshake/roles/server/server.h"
#include "transport/conn/loop/crecv/collect.h"
#include "transport/packet/header/packet/header.h"


typedef struct {
  const u8*         priv;        
  const u8*         pub;         
  const u8*         cert_seed;   
  const u8*         scid;        
  u8                scid_len;    
  const u8*         random;      
  const wired_span* chain;       
  usz               chain_count; 
  u64               max_data; 
  u64 max_streams_bidi; 
  u64 max_datagram_frame_size; 
  const u8* san_ipv4;
  u64 now_secs;
  const u8* retry_odcid;
  u8 retry_odcid_len;
  const u8* ticket_key;
  const u8* pref_v4;      
  const u8* pref_v6;      
  u16       pref_v4_port; 
  u16       pref_v6_port; 
  const char* raw_alpns;
} wired_srvboot_id;

int wired_srvboot_is_initial(const u8* dg, usz len);

int wired_srvboot_is_zerortt(const u8* dg, usz len);

typedef struct {
  wired_server*  s; 
  wired_srvloop* l; 
} wired_srvboot_conn;

typedef struct {
  const wired_srvboot_id* id;    
  wired_mspan             dgram; 
} wired_srvboot_in;

#define WIRED_SRVBOOT_FLIGHT_MAX 12

typedef struct {
  wired_obuf* initial; 
  wired_obuf* flight;  
  usz dgram_len[WIRED_SRVBOOT_FLIGHT_MAX]; 
  usz dgram_count; 
  u64 client_pn;   
} wired_srvboot_out;

int wired_srvboot_accept(
    const wired_srvboot_conn* conn,
    const wired_srvboot_in*   in,
    wired_srvboot_out*        out);

usz wired_srvboot_vneg(wired_span dg, u8* out, usz cap);

#define WIRED_SRVBOOT_ZERORTT_MAX 32
#define WIRED_SRVBOOT_ZERORTT_DG_MAX 1500

typedef struct {
  crecv        cr;  
  wired_header hdr; 
  u64 largest_pn;   
  int any;          
  usz opened;       
  u64 ack_pn;
  usz hrr_off;
  usz ini_tx_off;
  u64 ecn_ect0;
  u64 ecn_ect1;
  u64 ecn_ce;
  u8 alt_dcid[WIRED_MAX_CID_LEN];
  u8 alt_dcid_len;
  u8 zerortt_dg[WIRED_SRVBOOT_ZERORTT_MAX][WIRED_SRVBOOT_ZERORTT_DG_MAX];
  usz zerortt_len[WIRED_SRVBOOT_ZERORTT_MAX];
  usz zerortt_n;
} wired_srvboot_acc;

void wired_srvboot_acc_reset(wired_srvboot_acc* a);

u64 wired_srvboot_flight_pn(wired_srvboot_acc* a);

int wired_srvboot_acc_feed(wired_srvboot_acc* a, wired_mspan dg);

void wired_srvboot_acc_ecn_note(wired_srvboot_acc* a, u8 ecn);

void wired_srvboot_acc_hold(wired_srvboot_acc* a, wired_mspan dg);

usz wired_srvboot_acc_zerortt_count(const wired_srvboot_acc* a);

wired_span wired_srvboot_acc_zerortt_take(const wired_srvboot_acc* a, usz i);

void wired_srvboot_acc_allow(wired_srvboot_acc* a, wired_span dcid);

usz wired_srvboot_partial_ack(
    wired_srvboot_acc* a, wired_span scid, u8* out, usz cap);

int wired_srvboot_acc_complete(const wired_srvboot_acc* a);

#define WIRED_SRVBOOT_HRR 2

int wired_srvboot_accept_acc(
    const wired_srvboot_conn* conn,
    const wired_srvboot_id*   id,
    wired_srvboot_acc*        a,
    wired_srvboot_out*        out);

usz wired_srvboot_refusal(
    const wired_srvboot_acc* a,
    wired_span               scid,
    u64                      error_code,
    u8*                      out,
    usz                      cap);
 
#endif