srvloop.h

Go to the documentation of this file.

#ifndef WIRED_SRVLOOP_SRVLOOP_H
#define WIRED_SRVLOOP_SRVLOOP_H
 
#include "app/http3/core/h3/control.h"
#include "app/http3/core/h3/priority.h"
#include "app/http3/request/h3reqdrive/request_drive.h"
#include "app/http3/server/h3srv/state.h"
#include "common/bytes/span/span.h"
#include "tls/handshake/roles/server/server.h"
#include "transport/conn/pnspace/pnspaces/recv_spaces.h"
#include "transport/packet/frame/frame/connctl.h"
#include "transport/recovery/detect/recovery/ackpolicy.h"


#define WIRED_SRVLOOP_MAX_ACK_DELAY_MS 25

typedef int (*wired_srvloop_handler)(
    void*                       ctx,
    const wired_h3reqdrive_req* req,
    u64                         offset,
    quic_obuf*                  body_out,
    const char**                content_type,
    int*                        more,
    u64*                        total_size);

#define WIRED_SRVLOOP_MAX_STREAMS 40

typedef struct {
  int in_use;               
  u64 stream_id;            
  wired_h3reqdrive_req req; 
  u8 req_scratch[512];      
  /* RFC 9000 2.2: this stream reassembled across datagrams. curl splits one
   * request's HEADERS and DATA into separate STREAM frames in separate 1-RTT
   * packets; each frame's data is written at its offset here and the request
   * is decoded only once FIN arrives.
   * ponytail: overflow past req_buf is truncated. */
  u8  req_buf[2048]; 
  usz req_len;       
  u8  req_fin;       
  int req_done;      
  int req_incomplete;
  u8 req_wrap[2080];
  quic_h3_priority priority;
} wired_srvloop_stream_slot;

#define WIRED_SRVLOOP_MAX_PENDING_PRIORITY 8

typedef struct {
  int              in_use;    
  u64              stream_id; 
  quic_h3_priority priority;  
} wired_srvloop_pending_priority;

#define WIRED_SRVLOOP_CTRL_BUF_CAP 512

typedef struct {
  u8  buf[WIRED_SRVLOOP_CTRL_BUF_CAP]; 
  usz len;    
  usz parsed; 
} wired_srvloop_ctrl_stream;

#define WIRED_SRVLOOP_MAX_WT_STREAMS 6

#define WIRED_SRVLOOP_WT_BUF_CAP 49152

#define WIRED_SRVLOOP_WT_MAX_RANGES 8

typedef struct {
  u64 base; 
  u64 range_lo[WIRED_SRVLOOP_WT_MAX_RANGES]; 
  u64 range_hi[WIRED_SRVLOOP_WT_MAX_RANGES]; 
  usz range_n;  
  usz frontier; 
} wired_srvloop_wt_window;

typedef struct {
  int in_use;    
  u64 stream_id; 
  usz                     sig_len;
  wired_srvloop_wt_window win; 
  u8  buf[WIRED_SRVLOOP_WT_BUF_CAP];
  u8  fin;     
  u64 fin_off; 
  int offered;
  int wt_session_slot;
  u64 delivered_len;
  int fin_delivered;
  u64 credit_advertised;
} wired_srvloop_wt_stream_slot;

#define WIRED_SRVLOOP_MAX_WT_UNI_STREAMS 6

typedef struct {
  int in_use;    
  u64 stream_id; 
  usz                     type_len;
  wired_srvloop_wt_window win; 
  u8  buf[WIRED_SRVLOOP_WT_BUF_CAP];
  u8  fin;     
  u64 fin_off; 
  int offered;
  int wt_session_slot;
  u64 delivered_len;
  int fin_delivered;
  u64 credit_advertised;
} wired_srvloop_wt_uni_stream_slot;

#define WIRED_SRVLOOP_MAX_RX_DATAGRAMS 4

#define WIRED_SRVLOOP_RX_DATAGRAM_CAP 1200

typedef struct {
  u8  buf[WIRED_SRVLOOP_RX_DATAGRAM_CAP]; 
  usz len;                                
} wired_srvloop_rx_datagram;

// NOLINTNEXTLINE(clang-analyzer-optin.performance.Padding)
typedef struct {
  wired_h3srv_state h3; 
  u8  cli_scid[20];     
  u8  cli_scid_len;     
  u64 tx_pn;            
  u64 hs_tx_pn;  
  u64 app_rx_pn; 
  int app_rx_seen; 
  u64 hs_rx_pn;    
  int hs_rx_seen;  
  quic_pnspaces_recv ack_recv;
  quic_ackpolicy     app_ack_policy; 
  quic_ackpolicy     hs_ack_policy;  
  u64 now_ms;
  int hs_done_sent; 
  int ticket_sent;  
  u8 confirm_frames[320];
  u16 confirm_frames_len;
  wired_srvloop_handler
        on_request; 
  void* req_ctx;    
  wired_srvloop_stream_slot streams[WIRED_SRVLOOP_MAX_STREAMS];
  wired_srvloop_wt_stream_slot wt_streams[WIRED_SRVLOOP_MAX_WT_STREAMS];
  wired_srvloop_wt_uni_stream_slot
      wt_uni_streams[WIRED_SRVLOOP_MAX_WT_UNI_STREAMS];
  int                  got_request;
  wired_h3reqdrive_req req; 
  u64 req_stream_id;        
  u8  done_slots[WIRED_SRVLOOP_MAX_STREAMS];
  usz done_n; 
  u8  incomplete_slots[WIRED_SRVLOOP_MAX_STREAMS];
  usz incomplete_n; 
  u8  frame_unexpected_slots[WIRED_SRVLOOP_MAX_STREAMS];
  usz frame_unexpected_n; 
  int peer_closed;        
  int resp_external;      
  u64 ack_lo[32]; 
  u64 ack_hi[32]; 
  usz ack_n;      
  wired_srvloop_rx_datagram rx_datagrams[WIRED_SRVLOOP_MAX_RX_DATAGRAMS];
  usz rx_datagram_n;
  u64 we_advertised_max_datagram;
  int datagram_violation;
  u64 closed_stream_id;
  int closed_stream_seen; 
  u64 max_data_seen;
  int max_data_seen_flag; 
  u64 max_stream_data_stream_id[WIRED_SRVLOOP_MAX_STREAMS];
  u64 max_stream_data_value[WIRED_SRVLOOP_MAX_STREAMS];
  usz max_stream_data_n;
  u64 wt_released_watermark;
  u64 wt_uni_released_watermark;
  int streams_blocked_seen_flag;
  u8  path_response_data[QUIC_PATH_DATA];
  int path_response_seen_flag; 
  u64 ecn_ect0;
  u64 ecn_ect1;
  u64 ecn_ce;
  wired_srvloop_pending_priority
      pending_priority[WIRED_SRVLOOP_MAX_PENDING_PRIORITY];
  wired_srvloop_ctrl_stream ctrl;
  quic_h3_control peer_ctrl;
  u16 priupdate_violation;
  u16 qpack_stream_violation;
  int wt_signal_mid_stream_violation;
  u64 wt_reset_stream_id;  
  u64 wt_reset_error_code; 
  int wt_reset_is_stop;    
  int wt_reset_seen; 
} wired_srvloop;

void wired_srvloop_set_handler(
    wired_srvloop* l, wired_srvloop_handler cb, void* ctx);

int wired_srvloop_init(wired_srvloop* l, const u8* cli_scid, u8 cli_scid_len);

int wired_srvloop_slot_for(wired_srvloop* l, u64 stream_id);

void wired_srvloop_priority_apply(
    wired_srvloop* l, u64 stream_id, const quic_h3_priority* p);

int wired_srvloop_priority_of(
    const wired_srvloop* l, u64 stream_id, quic_h3_priority* out);

void wired_srvloop_slot_release(wired_srvloop* l, u64 stream_id);

int wired_srvloop_wt_slot_find(const wired_srvloop* l, u64 stream_id);

int wired_srvloop_wt_slot_claim(wired_srvloop* l, u64 stream_id);

int wired_srvloop_wt_uni_slot_find(const wired_srvloop* l, u64 stream_id);

int wired_srvloop_wt_uni_slot_claim(wired_srvloop* l, u64 stream_id);

int wired_srvloop_wt_slot_claim_local(wired_srvloop* l, u64 stream_id);

void wired_srvloop_wt_slot_release(wired_srvloop* l, u64 stream_id);

void wired_srvloop_wt_uni_slot_release(wired_srvloop* l, u64 stream_id);

void wired_srvloop_wt_window_accept(
    wired_srvloop_wt_window* win,
    u64                      abs_off,
    usz                      n,
    usz*                     rel_off,
    usz*                     accepted_n);

void wired_srvloop_wt_window_slide(
    wired_srvloop_wt_window* win, u8* buf, usz cap, u64 delivered_to);

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

int wired_srvloop_step(
    const wired_srvloop_conn* conn, quic_mspan dgram, quic_obuf* out);

void wired_srvloop_ecn_note(wired_srvloop* l, u8 ecn);
 
#endif