ra8_io_stream_usbcdc.c

Go to the documentation of this file.

 
#include "ra8_io_stream_usbcdc.h"
 
#include <stdint.h>
 
#include "ra8_attributes.h"
#include "ra8_check.h"
#include "ra8_err.h"
#include "ra8_io_stream_backend.h"
#include "ra8_usb_pal.h"

static const char* const s_tag = "ra8_io_stream_usbcdc";

typedef enum : uint32_t {
  k_usbcdc_max_chunk = 65535, 
} ra8_io_usbcdc_const_t;

RA8_INTERNAL static ra8_err_t
internal_usbcdc_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");
  const ra8_io_stream_usbcdc_state_t* st   = (const ra8_io_stream_usbcdc_state_t*)ctx;
  uint32_t                            done = 0;
  while (done < len) {
    const uint32_t rem = len - done;
    const uint32_t chunk =
      (rem > (uint32_t)k_usbcdc_max_chunk) ? (uint32_t)k_usbcdc_max_chunk : rem;
    const ra8_err_t e = ra8_usb_pal_ep_send(st->ep_addr, &buf[done], (uint16_t)chunk);
    if (e != k_ra8_ok) {
      if (out_written != nullptr) {
        *out_written = done;
      }
      return e;
    }
    done += chunk;
  }
  if (out_written != nullptr) {
    *out_written = len;
  }
  return k_ra8_ok;
}

static const ra8_io_stream_iface_t s_usbcdc_iface = {
  .write = internal_usbcdc_write,
  .flush = nullptr,
};
 
ra8_err_t
ra8_io_stream_usbcdc_init(ra8_io_stream_t* s, ra8_io_stream_usbcdc_state_t* state, uint8_t ep_addr)
{
  RA8_CHECK_NULL_PTR(s, s_tag, "s must not be nullptr");
  RA8_CHECK_NULL_PTR(state, s_tag, "state must not be nullptr");
  state->ep_addr = ep_addr;
  return ra8_io_stream_bind(s, &s_usbcdc_iface, state);
}