irq.c

#include "sx1262/sx1262.h"
#include "sx1262/sx126x.h"
#include "mculibrary.h"
#include "networkif.h"
#include "metrics/metrics.h"
extern byte sx1262_initialized;
 
void sx1262_process_packet_from_chip(struct network_context *nctx, int len, int pos) {
  //  printf("Bytes received: %i at position %i\r\n",len,pos);
  uint8_t buf[258];
 
  buf[len] = 0;
  buf[len + 1] = 0;
  buf[len + 2] = 0;
 
  sx126x_read_buffer(nctx, pos, (uint8_t *)&buf, len);
  struct sx126x_pkt_status_lora_s pkt_status;
 
  sx126x_get_lora_pkt_status(nctx, &pkt_status);
  printf("[sx1262] lora Received rssi=0x%x, snr=0x%x, est_rssi=0x%x: \"%s\"\r\n", pkt_status.rssi_pkt_in_dbm, pkt_status.snr_pkt_in_db, pkt_status.signal_rssi_pkt_in_dbm, buf);
  sx1262_switch_to_rx(nctx);
  struct command *com;
 
  com = command_parse(buf, len);
  if (com == NULL) {
    IncMetric_PKTS_LORA_INVALID;
    return;
  }
 
  com->sourcedev = SOURCE_LORA;
  got_new_packet(com, 255 - pkt_status.rssi_pkt_in_dbm);
  IncMetric_PKTS_LORA_CTR_IN;
}
 
 
void sx1262_irq(int pin, void *opaque) {
  struct network_context *nctx = opaque;
 
  if (!sx1262_initialized) {
    return;
  }
  sx126x_irq_mask_t irqs;
 
  sx126x_get_irq_status(nctx, &irqs);
  if (irqs == 0) {
    // we get an IRQ on raising AND falling edge, so check this, we might not have a real IRQ
    return;
  }
#ifdef SX126X_DEBUG
  printf("[sx1262] IRQ Masks: %p\r\n", irqs);
#endif
  sx126x_clear_irq_status(nctx, 0xFFFF);
  if ((irqs & (1 << 0)) || (irqs & (1 << 9))) {   // TxDone or Timeout
    //tx done: go into rx mode
    transmit_complete_irq();
  }
  if (irqs & (1 << 1)) {
    // we received a packet!
    struct sx126x_rx_buffer_status_s bufstat;
    sx126x_get_rx_buffer_status(nctx, &bufstat);
    sx1262_process_packet_from_chip(nctx, bufstat.pld_len_in_bytes, bufstat.buffer_start_pointer);
  }
}