start refactoring transmitting
This commit is contained in:
parent
96d0599e20
commit
802fec74e2
@ -308,12 +308,10 @@ void mbusCommExec() {
|
|||||||
uint8_t receivedOctet = 0;
|
uint8_t receivedOctet = 0;
|
||||||
|
|
||||||
if ((mbusCommHandle.startTime != 0) && ((mbusCommHandle.startTime + 2500) < HAL_GetTick())) {
|
if ((mbusCommHandle.startTime != 0) && ((mbusCommHandle.startTime + 2500) < HAL_GetTick())) {
|
||||||
coloredMsg(LOG_RED, false, "TIMEOUT %d %ld %ld", mbusCommHandle.state, mbusCommHandle.startTime, HAL_GetTick());
|
|
||||||
mbusCommHandle.startTime = 0;
|
|
||||||
mbusCommHandle.state = MBCS_TIMEOUT;
|
mbusCommHandle.state = MBCS_TIMEOUT;
|
||||||
} else if (mbusCommHandle.waitForOctet) {
|
} else if (mbusCommHandle.waitForOctet) {
|
||||||
if (mbusCommHandle.receiveBuffer.readIdx >= mbusCommHandle.receiveBuffer.writeIdx) {
|
if (mbusCommHandle.receiveBuffer.readIdx >= mbusCommHandle.receiveBuffer.writeIdx) {
|
||||||
return;
|
return; // no data available, wait
|
||||||
}
|
}
|
||||||
receivedOctet = mbusCommHandle.receiveBuffer.buffer[mbusCommHandle.receiveBuffer.readIdx];
|
receivedOctet = mbusCommHandle.receiveBuffer.buffer[mbusCommHandle.receiveBuffer.readIdx];
|
||||||
mbusCommHandle.receiveBuffer.readIdx += 1;
|
mbusCommHandle.receiveBuffer.readIdx += 1;
|
||||||
|
Loading…
x
Reference in New Issue
Block a user