refactoring meterbus
This commit is contained in:
parent
6d3b3e12ca
commit
9198753e4b
@ -276,10 +276,12 @@ void mbusCommExec() {
|
||||
if (mbusCommHandle.waitForOctet) {
|
||||
// when data available, take from buffer and put into receivedOctet
|
||||
// otherwise return
|
||||
if (-1 == (receivedOctet = ringbufferGetOne(&(mbusCommHandle.receiveBuffer)))) {
|
||||
int ro = ringbufferGetOne(&(mbusCommHandle.receiveBuffer));
|
||||
if (-1 == ro) {
|
||||
return;
|
||||
}
|
||||
|
||||
receivedOctet = (uint8_t) ro;
|
||||
coloredMsg(LOG_RED, false, "RO: 0x%02x", receivedOctet);
|
||||
}
|
||||
|
||||
|
@ -74,7 +74,7 @@ uint8_t *ringbufferGet(ringbuffer_t *handle, uint32_t dataLen) {
|
||||
|
||||
int ringbufferGetOne(ringbuffer_t *handle) {
|
||||
int res = -1;
|
||||
if (! ringbufferEmpty(handle)) {
|
||||
if (handle->bufferReadIdx != handle->bufferWriteIdx) {
|
||||
uint8_t r = *(handle->buffer + handle->bufferReadIdx);
|
||||
handle->bufferReadIdx += 1;
|
||||
if (handle->bufferReadIdx == handle->bufferSize) {
|
||||
|
Loading…
x
Reference in New Issue
Block a user