request_drive.h

Go to the documentation of this file.

#ifndef WIRED_H3REQDRIVE_REQUEST_DRIVE_H
#define WIRED_H3REQDRIVE_REQUEST_DRIVE_H
 
#include "app/http3/core/h3/priority.h"
#include "app/qpack/qpack/dyntable.h"
#include "common/bytes/span/span.h"
#include "common/platform/sys/syscall.h"


typedef struct {
  wired_span path;      
  wired_span authority; 
} wired_h3reqdrive_get_in;

int wired_h3reqdrive_send_get(
    u64 stream_id, const wired_h3reqdrive_get_in* in, wired_obuf* out);

typedef struct {
  wired_span method;    
  wired_span path;      
  wired_span authority; 
  wired_span body;      
} wired_h3reqdrive_send_in;

int wired_h3reqdrive_send_method(
    u64 stream_id, const wired_h3reqdrive_send_in* in, wired_obuf* out);

#define WIRED_H3REQDRIVE_MAX_HDRS 32

typedef struct {
  u16 name_off;  
  u16 name_len;  
  u16 value_off; 
  u16 value_len; 
} wired_h3reqdrive_hdr;

typedef struct {
  const u8* method;     
  usz       method_len; 
  const u8* scheme;     
  usz       scheme_len; 
  const u8* authority;  
  usz         authority_len; 
  const u8*   path;          
  usz         path_len;      
  const u8*   protocol;      
  usz         protocol_len;  
  const u8*   body;     
  usz         body_len; 
  h3_priority priority; 
  const u8*   origin;   
  usz origin_len;       
  u8  wt_avail[256];
  usz wt_avail_len; 
  u8  cookie[512];
  usz cookie_len; 
  int expect_continue;
  int frame_unexpected;
  u16 too_large_status;
  const u8* hdr_base;
  wired_h3reqdrive_hdr hdrs[WIRED_H3REQDRIVE_MAX_HDRS];
  usz                  hdr_count; 
  u64 qpack_ric;
  u64 qpack_trailer_ric;
  int qpack_failed;
} wired_h3reqdrive_req;

static inline wired_span wired_h3req_path(const wired_h3reqdrive_req* r) {
  return wired_span_of(r->path, r->path_len);
}

int wired_http_req_header(
    const wired_h3reqdrive_req* req, wired_span name, wired_span* out);

int wired_h3reqdrive_recv_get(
    wired_span stream_data, wired_mspan scratch, wired_h3reqdrive_req* r);

int wired_h3reqdrive_recv_get_dyn(
    wired_span            stream_data,
    wired_mspan           scratch,
    const qpack_dyn*      dyn,
    wired_h3reqdrive_req* r);
 
#endif