session.h

Go to the documentation of this file.

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


typedef enum {
  WIRED_WT_UNESTABLISHED, 
  WIRED_WT_ESTABLISHED,   
  WIRED_WT_DRAINING,      
  WIRED_WT_CLOSED,        
} wired_wt_state;

#define WIRED_WT_MAX_BUFFERED_STREAMS 4

#define WIRED_WT_MAX_BUFFERED_DATAGRAMS 4

#define WIRED_WT_BUFFERED_DATAGRAM_CAP 256

typedef struct {
  int in_use;    
  u64 stream_id; 
} wired_wt_buffered_stream;

typedef struct {
  int in_use;                               
  u8  data[WIRED_WT_BUFFERED_DATAGRAM_CAP]; 
  usz len; 
} wired_wt_buffered_datagram;

typedef struct {
  wired_wt_state state;             
  u64            connect_stream_id; 
  wired_wt_buffered_stream
      streams[WIRED_WT_MAX_BUFFERED_STREAMS]; 
  wired_wt_buffered_datagram
      datagrams[WIRED_WT_MAX_BUFFERED_DATAGRAMS]; 
  u64 max_streams_bidi;    
  u64 max_streams_uni;     
  u64 opened_streams_bidi; 
  u64 opened_streams_uni;  
  u64 max_data;  
  u64 sent_data; 
} wired_wt_session;

void wired_wt_session_init(wired_wt_session* s, u64 connect_stream_id);

int wired_wt_session_establish(wired_wt_session* s);

int wired_wt_session_drain(wired_wt_session* s);

int wired_wt_session_close(wired_wt_session* s);

int wired_wt_session_offer_stream(wired_wt_session* s, u64 stream_id);

int wired_wt_session_offer_datagram(wired_wt_session* s, quic_span data);

int wired_wt_session_set_max_streams(
    wired_wt_session* s, int bidi, u64 max_streams);

int wired_wt_session_stream_open_allowed(const wired_wt_session* s, int bidi);

void wired_wt_session_note_stream_opened(wired_wt_session* s, int bidi);

int wired_wt_session_set_max_data(wired_wt_session* s, u64 max_data);

int wired_wt_session_data_send_allowed(const wired_wt_session* s, usz len);

void wired_wt_session_note_data_sent(wired_wt_session* s, usz len);
 
#endif