moqssts.h

Go to the documentation of this file.

#ifndef MOQSSTS_H
#define MOQSSTS_H
 
#include "common/platform/sys/syscall.h"


#define MOQSSTS_MAX_MEMBERS 4

#define MOQSSTS_MAX_SETS 32

#define MOQSSTS_ALG_DEFAULT 0x0ULL

#define MOQSSTS_ALG_BACKPRESSURE 0xff01ULL

#define MOQSSTS_NONE (-1)

#define MOQSSTS_UNLIMITED_KBPS (~0ULL / 4)

#define MOQSSTS_DEPTH_TARGET 1ULL

#define MOQSSTS_DOWNSHIFT_DEPTH 2ULL

#define MOQSSTS_UPSHIFT_GOP_STREAK 5ULL

#define MOQSSTS_COOLDOWN_HIGH_STREAK 2ULL

#define MOQSSTS_EV_HELD 0

#define MOQSSTS_EV_COOLDOWN_EXIT 1

#define MOQSSTS_EV_UPSHIFT 2

#define MOQSSTS_EV_DOWNSHIFT 3

typedef struct {
  u64 track_id;
  u64 threshold_kbps;
} moqssts_member;

typedef struct {
  u64 set_id;
  u64 algorithm_id;
  u64 weight;
  u64 activate;
  u8 rank;
  usz n_members;
  moqssts_member m[MOQSSTS_MAX_MEMBERS];
} moqssts_set;

typedef struct {
  u64 tier;
  u64 clear_streak;
  int in_cooldown;
  u64 cooldown_ref;
  u64 high_streak;
} moqssts_bp;

typedef struct {
  u64 depth;
  int timed_out;
} moqssts_obs;

int moqssts_alg_supported(u64 id);

int moqssts_set_active(const moqssts_set* s);

u64 moqssts_budget_kbps(u64 est_kbps, u64 cap_kbps);

u64 moqssts_active_depth(const moqssts_set* sets, usz n, const u64* open);

void moqssts_default_decide(
    u64 budget_kbps, const moqssts_set* sets, usz n, int* out);

void moqssts_bp_init(moqssts_bp* st);

moqssts_obs moqssts_obs_make(u64 depth, u64 timeouts);

int moqssts_bp_observe(moqssts_bp* st, moqssts_obs ob);

int moqssts_bp_decide(
    moqssts_bp*        st,
    const moqssts_set* sets,
    usz                n,
    const u64*         open,
    u64                timeouts,
    int*               out);
 
#endif