ra8_c6link_mdl_msg.h

Go to the documentation of this file.

#pragma once
 
#include <stddef.h>
#include <stdint.h>
 
#include "ra8_err.h"
#include "ra8_mdl_http.h"
#include "ra8_mdl_protocol.h"
 
#ifdef __cplusplus
extern "C" {
#endif

typedef ra8_err_t (*ra8_mdl_service_dispatch_fn)(void*          ctx,
                                                 uint32_t       operation,
                                                 const uint8_t* request,
                                                 size_t         request_len,
                                                 uint8_t*       response,
                                                 size_t         response_cap,
                                                 size_t*        response_len);

typedef struct ra8_mdl_service_backend {
  ra8_err_t (*begin)(void* ctx, const ra8_mdl_request_t* request);
  ra8_err_t (*read)(void*                    ctx,
                    uint8_t*                 out,
                    uint16_t                 cap,
                    uint16_t*                got,
                    uint64_t*                total_bytes,
                    bool*                    complete,
                    uint8_t                  sha256[k_ra8_mdl_sha256_bytes],
                    ra8_mdl_http_response_t* response); 
  ra8_err_t (*cancel)(void* ctx); 
  void* ctx;                      
} ra8_mdl_service_backend_t;

typedef enum : uint16_t {
  k_ra8_mdl_decode_arena_bytes = k_ra8_mdl_url_max + k_ra8_mdl_user_agent_max +
                                 k_ra8_mdl_referer_max + k_ra8_mdl_etag_max +
                                 k_ra8_mdl_http_date_max + 512U, 
  k_ra8_mdl_decode_align       = 8U, 
} ra8_mdl_decode_arena_limit_t;

typedef struct ra8_mdl_decode_arena {
  alignas(k_ra8_mdl_decode_align) uint8_t bytes[k_ra8_mdl_decode_arena_bytes];
  size_t used; 
} ra8_mdl_decode_arena_t;

typedef struct ra8_mdl_service {
  ra8_mdl_service_backend_t backend;       
  uint32_t                  next_job_id;   
  uint32_t                  active_job_id; 
  uint32_t                  next_sequence; 
  uint64_t                  next_offset;   
  mdl_format_t              active_format; 
  bool                      active;        
  ra8_mdl_decode_arena_t    arena;         
} ra8_mdl_service_t;

[[nodiscard]] ra8_err_t ra8_mdl_service_init(ra8_mdl_service_t*               service,
                                             const ra8_mdl_service_backend_t* backend);

[[nodiscard]] ra8_err_t ra8_mdl_service_dispatch(void*          ctx,
                                                 uint32_t       operation,
                                                 const uint8_t* request,
                                                 size_t         request_len,
                                                 uint8_t*       response,
                                                 size_t         response_cap,
                                                 size_t*        response_len);
 
#ifdef __cplusplus
}
#endif