moqdata.h

Go to the documentation of this file.

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


#define MOQDATA_OK 1
#define MOQDATA_INSUFFICIENT 0
#define MOQDATA_VIOLATION (-1)
 
/* Unidirectional stream types (3.4). */
#define MOQDATA_STREAM_INSUFFICIENT 0
#define MOQDATA_STREAM_CONTROL 1
#define MOQDATA_STREAM_FETCH 2
#define MOQDATA_STREAM_SUBGROUP 3
#define MOQDATA_STREAM_PADDING 4
#define MOQDATA_STREAM_UNKNOWN 5

#define MOQDATA_TYPE_SETUP 0x2F00ULL
#define MOQDATA_TYPE_FETCH_HEADER 0x05ULL
#define MOQDATA_TYPE_PADDING 0x132B3E28ULL
#define MOQDATA_MSG_TYPE 0x70ULL

int moqdata_classify(wired_span in, usz* off);

int moqdata_type_valid(u64 type);
int moqdata_type_props(u64 type);
u64 moqdata_type_sgid_mode(u64 type);
int moqdata_type_end_of_group(u64 type);
int moqdata_type_default_priority(u64 type);
int moqdata_type_first_object(u64 type);

typedef struct {
  u64 type;
  u64 track_alias;
  u64 group_id;
  u64 subgroup_id;
  int subgroup_id_pending;
  u64 priority;
} moqdata_subhdr;

int moqdata_subhdr_take(wired_span buf, usz* off, moqdata_subhdr* h);
int moqdata_subhdr_put(wired_mspan buf, usz* off, const moqdata_subhdr* h);

void moqdata_subhdr_resolve(moqdata_subhdr* h, u64 first_object_id);

typedef struct {
  int has_props;
  int have_prev;
  u64 prev_id;
} moqdata_objseq;

moqdata_objseq moqdata_objseq_of(u64 type);

typedef struct {
  u64 object_id;
  u64 status;
  wired_span payload;
} moqdata_obj;

#define MOQDATA_STATUS_NORMAL 0x0ULL
#define MOQDATA_STATUS_END_OF_GROUP 0x3ULL
#define MOQDATA_STATUS_END_OF_TRACK 0x4ULL

int moqdata_obj_take(
    wired_span buf, usz* off, moqdata_objseq* seq, moqdata_obj* out);

int moqdata_obj_put(
    wired_mspan buf, usz* off, u64 id_delta, wired_span payload);

int moqdata_obj_put_status(wired_mspan buf, usz* off, u64 id_delta, u64 status);

typedef struct {
  u64 track_alias;
  u64 group_id;
  wired_span payload;
} moqdata_msg;

#define MOQDATA_MSG_OVERHEAD 37

int moqdata_msg_build(wired_mspan buf, usz* off, const moqdata_msg* m);

#define MOQDATA_BLOB_CHUNK 16384

#define MOQDATA_BLOB_WIRE_CAP(n) \
  ((n) + MOQDATA_MSG_OVERHEAD + 8 * ((n) / MOQDATA_BLOB_CHUNK + 1))

usz moqdata_blob_build(wired_mspan buf, u64 track_alias, wired_span blob);
 
#endif