Porównaj commity

...

2 Commity

Autor SHA1 Wiadomość Data
Piotr Wilkon c9066cea5a non-APRS in FX.25 mode 2023-09-05 11:01:44 +02:00
Piotr Wilkon b898d05a7f fixed non-APRS RX problem 2023-09-05 10:24:53 +02:00
1 zmienionych plików z 44 dodań i 30 usunięć

Wyświetl plik

@ -41,6 +41,8 @@ struct Ax25ProtoConfig Ax25Config;
#define MAX_TRANSMIT_RETRY_COUNT 8 //max number of retries if channel is busy
#define SYNC_BYTE 0x7E //preamble/postamble octet
struct FrameHandle
{
uint16_t start;
@ -169,7 +171,7 @@ void Ax25ClearReceivedFrameBitmap(void)
frameReceived = 0;
}
#ifdef ENABLE_FX25
static void removeLastFrameFromRxBuffer(void)
{
rxBufferHead = rxFrame[rxFrameHead].start;
@ -180,7 +182,7 @@ static void removeLastFrameFromRxBuffer(void)
rxFrameBufferFull = false;
}
#ifdef ENABLE_FX25
static void *writeFx25Frame(uint8_t *data, uint16_t size)
{
@ -375,6 +377,7 @@ static struct FrameHandle* parseFx25Frame(uint8_t *frame, uint16_t size, uint16_
endParseFx25Frame:
*crc = 0xFFFF;
i = initialRxBufferHead;
for(uint16_t j = 0; j < (k - 2); j++)
{
for(uint8_t b = 0; b < 8; b++)
@ -384,18 +387,29 @@ endParseFx25Frame:
i %= FRAME_BUFFER_SIZE;
}
*crc ^= 0xFFFF;
if((rxBuffer[i] == (*crc & 0xFF) )
&& (rxBuffer[(i + 1) % FRAME_BUFFER_SIZE] == ((*crc >> 8) & 0xFF))) //check CRC
{
h->size = k - 2;
return h;
}
else
{
removeLastFrameFromRxBuffer();
return NULL;
uint16_t pathEnd = initialRxBufferHead;
for(uint16_t j = 0; j < (k - 2); j++)
{
if(rxBuffer[pathEnd] & 1)
break;
pathEnd++;
pathEnd %= FRAME_BUFFER_SIZE;
}
if(Ax25Config.allowNonAprs || (((rxBuffer[(pathEnd + 1) % FRAME_BUFFER_SIZE] == 0x03) && (rxBuffer[(pathEnd + 2) % FRAME_BUFFER_SIZE] == 0xF0))))
{
h->size = k - 2;
return h;
}
}
removeLastFrameFromRxBuffer();
return NULL;
}
#endif
@ -523,10 +537,13 @@ void Ax25BitParse(uint8_t bit, uint8_t modem)
{
if(rx->rx == RX_STAGE_FRAME) //if we are in frame, this is the end of the frame
{
if((rx->frameIdx > 15)) //correct frame must be at least 16 bytes long
if(rx->frameIdx >= 17) //correct frame must be at least 17 bytes long (source+destination+control+CRC)
{
uint16_t i = 0;
for(; i < rx->frameIdx - 2; i++) //look for path end bit
uint16_t i = 13;
//start from 13, which is the SSID of source
//end either at the 69th byte, which is the SSID of th 8th digipeater
//or at frame size - 3, which is the last byte before PID/control field
for(; i < ((rx->frameIdx < 73) ? (rx->frameIdx - 3) : 70); i++) //look for path end bit
{
if(rx->frame[i] & 1)
break;
@ -535,14 +552,6 @@ void Ax25BitParse(uint8_t bit, uint8_t modem)
//if non-APRS frames are not allowed, check if this frame has control=0x03 and PID=0xF0
if(Ax25Config.allowNonAprs || (((rx->frame[i + 1] == 0x03) && (rx->frame[i + 2] == 0xF0))))
{
rx->crc = 0xFFFF;
for(i = 0; i < rx->frameIdx - 2; i++)
{
for(uint8_t k = 0; k < 8; k++)
{
calculateCRC((rx->frame[i] >> k) & 1, &(rx->crc));
}
}
rx->crc ^= 0xFFFF;
if((rx->frame[rx->frameIdx - 2] == (rx->crc & 0xFF)) && (rx->frame[rx->frameIdx - 1] == ((rx->crc >> 8) & 0xFF))) //check CRC
{
@ -582,24 +591,19 @@ void Ax25BitParse(uint8_t bit, uint8_t modem)
rx->receivedByte = 0;
rx->receivedBitIdx = 0;
rx->frameIdx = 0;
rx->crc = 0xFFFF;
return;
}
else
rx->rx = RX_STAGE_FRAME;
#ifdef ENABLE_FX25
}
if(rx->rx != RX_STAGE_FX25_FRAME)
{
#else
#ifndef ENABLE_FX25
{
//this condition must not be checked when FX.25 is enabled
//because FX.25 parity bytes and tags contain >= 7 consecutive ones
if((rx->rawData & 0x7F) == 0x7F) //received 7 consecutive ones, this is an error
{
rx->rx = RX_STAGE_FLAG;
rx->rx = RX_STAGE_IDLE;
rx->receivedByte = 0;
rx->receivedBitIdx = 0;
rx->frameIdx = 0;
@ -611,11 +615,21 @@ void Ax25BitParse(uint8_t bit, uint8_t modem)
return;
}
if(rx->rawData & 0x01) //received bit 1
rx->receivedByte |= 0x80; //store it
if(++rx->receivedBitIdx >= 8) //received full byte
{
if(rx->frameIdx >= 2)
{
for(uint8_t k = 0; k < 8; k++)
{
calculateCRC((rx->frame[rx->frameIdx - 2] >> k) & 1, &(rx->crc));
}
}
#ifdef ENABLE_FX25
//end of FX.25 reception, that is received full block
if((rx->fx25Mode != NULL) && (rx->frameIdx == (rx->fx25Mode->K + rx->fx25Mode->T)))
@ -673,7 +687,7 @@ uint8_t Ax25GetTxBit(void)
{
if(txDelayElapsed < txDelay)
{
txByte = 0x7E;
txByte = SYNC_BYTE;
txDelayElapsed++;
}
else
@ -815,7 +829,7 @@ transmitTail:
{
if(txTailElapsed < txTail)
{
txByte = 0x7E;
txByte = SYNC_BYTE;
txTailElapsed++;
}
else //tail transmitted, stop transmission