Mirrors/knx
1
0
Fork 0
mirror of https://github.com/thelsing/knx.git synced 2024-12-18 19:08:18 +01:00
Code Issues Packages Projects Releases Wiki Activity

fixes modulo in rx queue

Browse Source
This commit is contained in:
Marco Scholl 2024-08-03 21:27:00 +02:00
parent e69f63611a
commit 84a0ce3c22
No known key found for this signature in database
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/knx/tpuart_data_link_layer.cpp
View File

@ -1204,19 +1204,19 @@ void TpUartDataLinkLayer::processRxQueue()
void TpUartDataLinkLayer::pushByteToRxQueue(uint8_t byte) void TpUartDataLinkLayer::pushByteToRxQueue(uint8_t byte)
{ {
_rxBuffer[_rxBufferFront] = byte; _rxBuffer[_rxBufferFront] = byte;
_rxBufferFront = (_rxBufferFront + 1) % MAX_RX_QUEUE_BYTES; _rxBufferFront = (_rxBufferFront + 1) % (MAX_RX_QUEUE_BYTES);
} }
uint8_t TpUartDataLinkLayer::pullByteFromRxQueue() uint8_t TpUartDataLinkLayer::pullByteFromRxQueue()
{ {
uint8_t byte = _rxBuffer[_rxBufferRear]; uint8_t byte = _rxBuffer[_rxBufferRear];
_rxBufferRear = (_rxBufferRear + 1) % MAX_RX_QUEUE_BYTES; _rxBufferRear = (_rxBufferRear + 1) % (MAX_RX_QUEUE_BYTES);
return byte; return byte;
} }
uint16_t TpUartDataLinkLayer::availableInRxQueue() uint16_t TpUartDataLinkLayer::availableInRxQueue()
{ {
return ((_rxBufferFront == _rxBufferRear) ? MAX_RX_QUEUE_BYTES : (((MAX_RX_QUEUE_BYTES - _rxBufferFront) + _rxBufferRear) % MAX_RX_QUEUE_BYTES)) - 1; return ((_rxBufferFront == _rxBufferRear) ? (MAX_RX_QUEUE_BYTES) : ((((MAX_RX_QUEUE_BYTES) - _rxBufferFront) + _rxBufferRear) % (MAX_RX_QUEUE_BYTES))) - 1;
} }
#endif #endif