ra8_c6link_pump.c

Go to the documentation of this file.

 
#include <stdint.h>
 
#include "ra8_attributes.h"
#include "ra8_c6link.h"
#include "ra8_c6link_internal.h"

RA8_INTERNAL static bool internal_c6link_pump_handshake(ra8_c6link_t* link)
{
  for (uint16_t waited = 0U; waited < (uint16_t)k_ra8_c6link_hs_wait_ms;
       waited          = (uint16_t)(waited + (uint16_t)k_ra8_c6link_hs_poll_ms)) {
    if (link->transport.handshake_active(link->transport.ctx)) {
      return true;
    }
    link->transport.delay_ms(link->transport.ctx, (uint16_t)k_ra8_c6link_hs_poll_ms);
  }
  return false;
}

RA8_INTERNAL static bool internal_c6link_pump_receive(ra8_c6link_t* link, ra8_c6link_stats_t* stats)
{
  ra8_c6link_rx_view_t           view = {};
  const ra8_c6link_frame_class_t cls  = priv_c6link_frame_classify(link->rx, &view);
 
  switch (cls) {
    case k_ra8_c6link_frame_idle:
      stats->idle++;
      return false;
    case k_ra8_c6link_frame_malformed:
      stats->malformed++;
      return false;
    case k_ra8_c6link_frame_bad_checksum:
      stats->bad_checksum++;
      return false;
    case k_ra8_c6link_frame_data:
    default:
      break;
  }
 
  stats->data++;
  return priv_c6link_dispatch(link, &view);
}
 
RA8_PRIV ra8_err_t priv_c6link_pump(ra8_c6link_t*       link,
                                    uint16_t            max_transactions,
                                    ra8_c6link_stats_t* stats)
{
  if ((link == nullptr) || (stats == nullptr)) {
    return k_ra8_err_null_ptr;
  }
  link->stats       = stats;
  uint16_t  misses  = 0U;
  ra8_err_t verdict = k_ra8_ok;
 
  for (uint16_t i = 0U; i < max_transactions; i++) {
    if (!internal_c6link_pump_handshake(link)) {
      stats->hs_timeouts++;
      misses++;
      if (misses >= (uint16_t)k_ra8_c6link_hs_giveup) {
        break;
      }
      continue;
    }
    misses = 0U;
 
    if (link->tx_len != 0U) {
      priv_c6link_frame_seal(link->tx, link->tx_if, 0U, link->tx_len);
      link->tx_len = 0U;
    } else {
      priv_c6link_frame_filler(link->tx);
    }
 
    const ra8_err_t moved = link->transport.transfer(link->transport.ctx,
                                                     link->tx,
                                                     link->rx,
                                                     (uint16_t)k_ra8_c6link_frame_bytes);
    if (moved != k_ra8_ok) {
      verdict = k_ra8_err_spi_error;
      break;
    }
    stats->transfers++;
 
    if (internal_c6link_pump_receive(link, stats)) {
      break;
    }
    link->transport.delay_ms(link->transport.ctx, (uint16_t)k_ra8_c6link_gap_ms);
  }
 
  link->stats = nullptr;
  if (verdict != k_ra8_ok) {
    return verdict;
  }
  return (stats->transfers == 0U) ? k_ra8_err_hw_timeout : k_ra8_ok;
}