Git-Mirrors/RNode_Firmware_CE
1
0
Fork 0
mirror of https://github.com/liberatedsystems/RNode_Firmware_CE.git synced 2025-06-02 13:22:11 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

Cleanup

Browse source
This commit is contained in:
jacob.eva 2025-02-11 18:26:26 +00:00
parent accb5d907c
commit 1d62fdd52e
No known key found for this signature in database
GPG key ID: 0B92E083BBCCAA1E
1 changed files with 16 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

26
RNode_Firmware_CE.ino
View file

@ -659,10 +659,10 @@ void flush_queue(RadioInterface* radio) {
}
queue_flushing = false;
queue_height[index] = 0;
queued_bytes[index] = 0;
selected_radio->updateAirtime();
queue_flushing = false;
radio->updateAirtime();
#if HAS_DISPLAY
display_tx[radio->getIndex()] = true;
@ -670,16 +670,12 @@ void flush_queue(RadioInterface* radio) {
}
void pop_queue(RadioInterface* radio) {
uint8_t index = radio->getIndex();
uint8_t index = radio->getIndex();
if (!queue_flushing) {
queue_flushing = true;
led_tx_on(); uint16_t processed = 0;
#if MCU_VARIANT == MCU_ESP32 || MCU_VARIANT == MCU_NRF52
if (!fifo16_isempty(&packet_starts[index])) {
#else
if (!fifo16_isempty_locked(&packet_starts[index])) {
#endif
uint16_t start = fifo16_pop(&packet_starts[index]);
uint16_t length = fifo16_pop(&packet_lengths[index]);
@ -691,6 +687,7 @@ void pop_queue(RadioInterface* radio) {
transmit(radio, length); processed++;
}
queue_height[index] -= processed;
queued_bytes[index] -= length;
}
@ -701,10 +698,11 @@ void pop_queue(RadioInterface* radio) {
radio->updateAirtime();
queue_flushing = false;
#if HAS_DISPLAY
display_tx[radio->getIndex()] = true;
#endif
}
void transmit(RadioInterface* radio, uint16_t size) {
@ -728,8 +726,15 @@ void transmit(RadioInterface* radio, uint16_t size) {
// Only start a new packet if this is a split packet and it has
// exceeded the length of a single packet
if (written == 255 && header & 0x0F) {
radio->endPacket(); radio->addAirtime();
if (written == 255 && isSplitPacket(header)) {
if (!radio->endPacket()) {
kiss_indicate_error(ERROR_MODEM_TIMEOUT);
kiss_indicate_error(ERROR_TXFAILED);
led_indicate_error(5);
hard_reset();
}
radio->addAirtime();
radio->beginPacket();
radio->write(header);
written = 1;
@ -875,6 +880,7 @@ void serial_callback(uint8_t sbyte) {
}
if (frame_len < CMD_L) cmdbuf[frame_len++] = sbyte;
}
if (frame_len == 4) {
selected_radio = interface_obj[interface];