ra8_io_stream_ram.c

Go to the documentation of this file.

 
#include "ra8_io_stream_ram.h"
 
#include <stddef.h>
#include <stdint.h>
#include <string.h>
 
#include "ra8_attributes.h"
#include "ra8_check.h"
#include "ra8_err.h"
#include "ra8_io_stream_backend.h"

static const char* const s_tag = "ra8_io_stream_ram";

RA8_INTERNAL static ra8_err_t
internal_ram_write(void* ctx, const uint8_t* buf, uint32_t len, uint32_t* out_written)
{
  RA8_CHECK_NULL_PTR(ctx, s_tag, "ctx must not be nullptr");
  RA8_CHECK_NULL_PTR(buf, s_tag, "buf must not be nullptr");
  ra8_io_stream_ram_state_t* st       = (ra8_io_stream_ram_state_t*)ctx;
  const uint32_t             room     = st->cap - st->len;
  const bool                 fits     = (len <= room);
  const uint32_t             accepted = fits ? len : room;
  (void)memcpy(&st->buf[st->len], buf, (size_t)accepted);
  st->len += accepted;
  if (out_written != nullptr) {
    *out_written = accepted;
  }
  return fits ? k_ra8_ok : k_ra8_err_no_mem;
}

static const ra8_io_stream_iface_t s_ram_iface = {
  .write = internal_ram_write,
  .flush = nullptr,
};
 
ra8_err_t ra8_io_stream_ram_init(ra8_io_stream_t*           s,
                                 ra8_io_stream_ram_state_t* state,
                                 uint8_t*                   buf,
                                 uint32_t                   cap)
{
  RA8_CHECK_NULL_PTR(s, s_tag, "s must not be nullptr");
  RA8_CHECK_NULL_PTR(state, s_tag, "state must not be nullptr");
  RA8_CHECK_NULL_PTR(buf, s_tag, "buf must not be nullptr");
  if (cap == 0U) {
    return k_ra8_err_invalid_size;
  }
  state->buf = buf;
  state->cap = cap;
  state->len = 0;
  return ra8_io_stream_bind(s, &s_ram_iface, state);
}
 
ra8_err_t ra8_io_stream_ram_used(const ra8_io_stream_ram_state_t* state, uint32_t* out_used)
{
  RA8_CHECK_NULL_PTR(state, s_tag, "state must not be nullptr");
  RA8_CHECK_NULL_PTR(out_used, s_tag, "out_used must not be nullptr");
  *out_used = state->len;
  return k_ra8_ok;
}