moqtrel.h

Go to the documentation of this file.

#ifndef WIRED_MOQTREL_H
#define WIRED_MOQTREL_H
 
#include "app/http3/server/srvloop/srvloop.h"
#include "app/webtransport/session/session/session.h"
#include "common/bytes/span/span.h"
#include "common/platform/sys/syscall.h"


#define WIRED_MOQTREL_POOL 4

#define WIRED_MOQTREL_CAP ((u64)3 * WIRED_SRVLOOP_WT_BUF_CAP)

#define WIRED_MOQTREL_ROUND_MAX 16384

#define WIRED_MOQTREL_STALL_MS 10000

#define WIRED_MOQTREL_HEADROOM \
  (WIRED_MOQTRUN_RELAY_FRAG_MAX + WIRED_SRVLOOP_WT_BUF_CAP + 16)

#define WIRED_MOQTREL_MAX_SUBS 31

#define WIRED_MOQTREL_MARKS 8

typedef struct {
  u64 sent;
  u64 last_ok_ms;
  int active;
  int shed;
  int fin_done;
  u64 end;
  u64 lead_id;
  u32 lead_skip;
  int before_start;
} moqtrel_sub;

typedef struct {
  u8 buf[WIRED_MOQTREL_CAP];
  u64 head;
  u64 tail;
  int in_use;
  int fin_seen;
  int held;
  wired_wt_session* pub;
  u64 pub_stream;
  u64 bound_ms;
  moqtrel_sub subs[WIRED_MOQTREL_MAX_SUBS];
  u64 mark_end[WIRED_MOQTREL_MARKS];
  u64 mark_ms[WIRED_MOQTREL_MARKS];
  u32 marks;
} moqtrel_buf;

void moqtrel_reset(moqtrel_buf* b);

int moqtrel_append(moqtrel_buf* b, wired_span src);

wired_span moqtrel_next_round(const moqtrel_buf* b, u32 sub);

void moqtrel_note_sent(moqtrel_buf* b, u32 sub, usz n, u64 now_ms);

void moqtrel_mark(moqtrel_buf* b, u64 now_ms);

u64 moqtrel_age_ms(const moqtrel_buf* b, u32 sub, u64 now_ms);

void moqtrel_reclaim(moqtrel_buf* b);

int moqtrel_should_hold(const moqtrel_buf* b);

int moqtrel_should_release(const moqtrel_buf* b);

int moqtrel_stalled(const moqtrel_buf* b, u32 sub, u64 now_ms);

int moqtrel_awaits_sub(const moqtrel_buf* b, u64 now_ms);

int moqtrel_all_done(const moqtrel_buf* b);
 
#endif