moqfetch.h

Go to the documentation of this file.

#ifndef MOQFETCH_H
#define MOQFETCH_H
 
#include "app/moqt/ctl/moqctl.h"


#define MOQFETCH_T_FETCH 0x16ULL
#define MOQFETCH_T_FETCH_OK 0x18ULL

#define MOQFETCH_ERR_INVALID_JOINING_REQUEST_ID \
  MOQCTL_ERR_INVALID_JOINING_REQUEST_ID

#define MOQFETCH_STANDALONE 0x1ULL
#define MOQFETCH_RELATIVE_JOINING 0x2ULL
#define MOQFETCH_ABSOLUTE_JOINING 0x3ULL

typedef struct {
  u64 request_id;
  u64 fetch_type;
  moqctl_ftn track;
  moqctl_loc start;
  moqctl_loc end;
  u64 joining_request_id;
  u64 joining_start;
  moqctl_params params;
} moqfetch_fetch;

int moqfetch_fetch_take(int ver, wired_span body, moqfetch_fetch* out);
int moqfetch_fetch_encode(wired_mspan buf, usz* off, const moqfetch_fetch* m);

typedef struct {
  u64 request_id;
  u64 fetch_type;
  int is_joining;
  u64 joining_request_id;
  u64 joining_start;
  moqctl_ftn track;
  moqctl_rangeloc range;
  moqctl_params params;
} moqfetch_req;

int moqfetch_req19_take(int ver, wired_span body, moqfetch_req* out);

int moqfetch_req19_encode(wired_mspan buf, usz* off, const moqfetch_req* m);

int moqfetch_req22_take(wired_span body, moqfetch_req* out);
int moqfetch_req22_encode(wired_mspan buf, usz* off, const moqfetch_req* m);

typedef struct {
  int inherit;
  int has_filter;
  moqctl_rangeloc range;
  int descending;
  int has_timeout;
  u64 timeout_ms;
} moqfetch_fill;

int moqfetch_fill_take(wired_span value, moqfetch_fill* out);

int moqfetch_fill_put(wired_mspan buf, usz* off, const moqfetch_fill* f);

typedef struct {
  u64 end_of_track;
  moqctl_loc end;
  moqctl_params params;
  wired_span track_properties;
} moqfetch_ok;

int moqfetch_ok_take(int ver, wired_span body, moqfetch_ok* out);
int moqfetch_ok_encode(wired_mspan buf, usz* off, const moqfetch_ok* m);

#define MOQFETCH_OBJ_GROUP_END (~0ULL)

moqctl_loc moqfetch_end19_incl(moqctl_loc wire);
moqctl_loc moqfetch_end19_wire(moqctl_loc incl);

moqctl_loc moqfetch_req_end(const moqctl_rangeloc* r, moqctl_loc largest);

int moqfetch_ok19_encode(wired_mspan buf, usz* off, const moqfetch_ok* m);

int moqfetch_hdr_take(wired_span buf, usz* off, u64* request_id);
int moqfetch_hdr_put(wired_mspan buf, usz* off, u64 request_id);

#define MOQFETCH_F_SUBGROUP_MASK 0x03ULL
#define MOQFETCH_F_OBJECT 0x04ULL
#define MOQFETCH_F_GROUP 0x08ULL
#define MOQFETCH_F_PRIORITY 0x10ULL
#define MOQFETCH_F_PROPS 0x20ULL
#define MOQFETCH_F_DATAGRAM 0x40ULL
#define MOQFETCH_EOR_NONEXISTENT 0x8CULL
#define MOQFETCH_EOR_UNKNOWN 0x10CULL
#define MOQFETCH_EOR_TIMED_OUT 0x20CULL

typedef struct {
  int descending;
  int eor_timed_out;
  int have_loc;
  int have_subgroup;
  int have_priority;
  u64 group;
  u64 object;
  u64 subgroup;
  u64 priority;
} moqfetch_seq;

typedef struct {
  u64 flags;
  u64 group;
  u64 object;
  int has_subgroup;
  u64 subgroup;
  u64 priority;
  int has_props;
  wired_span props;
  wired_span payload;
} moqfetch_obj;

int moqfetch_obj_take(
    wired_span buf, usz* off, moqfetch_seq* seq, moqfetch_obj* out);

int moqfetch_obj_put(
    wired_mspan buf, usz* off, moqfetch_seq* seq, const moqfetch_obj* o);

int moqfetch_obj_take_head(
    wired_span buf, usz* off, moqfetch_seq* seq, moqfetch_obj* out);

int moqfetch_obj_put_head(
    wired_mspan buf, usz* off, moqfetch_seq* seq, const moqfetch_obj* o);
 
#endif