From dc67fd9b87b0e86cea8d176d8b9bbce3e8a8676d Mon Sep 17 00:00:00 2001 From: jpe230 Date: Tue, 8 Mar 2022 23:49:29 -0600 Subject: Various improvements for the AnnePro2 (#16579) --- keyboards/annepro2/protocol.c | 40 ++++++++++++++++++++-------------------- 1 file changed, 20 insertions(+), 20 deletions(-) (limited to 'keyboards/annepro2/protocol.c') diff --git a/keyboards/annepro2/protocol.c b/keyboards/annepro2/protocol.c index 171ac5c239..ff30658cd7 100644 --- a/keyboards/annepro2/protocol.c +++ b/keyboards/annepro2/protocol.c @@ -20,38 +20,38 @@ /* UART communication protocol state */ protocol_t proto; -void protoInit(protocol_t *proto, void (*callback)(const message_t *)) { - proto->previousId = 0; +void proto_init(protocol_t *proto, void (*callback)(const message_t *)) { + proto->previous_id = 0; proto->callback = callback; proto->state = STATE_SYNC_1; proto->errors = 0; } -static uint8_t msgId = 0; -void protoTx(uint8_t cmd, const unsigned char *buf, int payloadSize, int retries) { - chDbgCheck(payloadSize <= MAX_PAYLOAD_SIZE); +static uint8_t msg_id = 0; +void proto_tx(uint8_t cmd, const unsigned char *buf, int payload_size, int retries) { + chDbgCheck(payload_size <= MAX_PAYLOAD_SIZE); const uint8_t header[5] = { - 0x7A, 0x1D, cmd, ++msgId, payloadSize, + 0x7A, 0x1D, cmd, ++msg_id, payload_size, }; /* We don't implement ACKs, yet some messages should not be lost. */ for (int i = 0; i < retries; i++) { sdWrite(&PROTOCOL_SD, header, sizeof(header)); - if (payloadSize) sdWrite(&PROTOCOL_SD, buf, payloadSize); + if (payload_size) sdWrite(&PROTOCOL_SD, buf, payload_size); } } static inline void messageReceived(protocol_t *proto) { - if (proto->buffer.msgId != proto->previousId) { + if (proto->buffer.msg_id != proto->previous_id) { /* It's not a resend / duplicate */ proto->callback(&proto->buffer); - proto->previousId = proto->buffer.msgId; + proto->previous_id = proto->buffer.msg_id; } proto->state = STATE_SYNC_1; } -void protoConsume(protocol_t *proto, uint8_t byte) { +void proto_consume(protocol_t *proto, uint8_t byte) { switch (proto->state) { case STATE_SYNC_1: if (byte == 0x7A) { @@ -76,18 +76,18 @@ void protoConsume(protocol_t *proto, uint8_t byte) { return; case STATE_ID: - proto->buffer.msgId = byte; + proto->buffer.msg_id = byte; proto->state = STATE_PAYLOAD_SIZE; return; case STATE_PAYLOAD_SIZE: - proto->buffer.payloadSize = byte; - if (proto->buffer.payloadSize > MAX_PAYLOAD_SIZE) { - proto->buffer.payloadSize = MAX_PAYLOAD_SIZE; + proto->buffer.payload_size = byte; + if (proto->buffer.payload_size > MAX_PAYLOAD_SIZE) { + proto->buffer.payload_size = MAX_PAYLOAD_SIZE; proto->errors++; } - proto->payloadPosition = 0; - if (proto->buffer.payloadSize == 0) { + proto->payload_position = 0; + if (proto->buffer.payload_size == 0) { /* No payload - whole message received */ messageReceived(proto); } else { @@ -98,9 +98,9 @@ void protoConsume(protocol_t *proto, uint8_t byte) { case STATE_PAYLOAD: /* NOTE: This could be read with sdReadTimeout probably, but that breaks * abstraction */ - proto->buffer.payload[proto->payloadPosition] = byte; - proto->payloadPosition++; - if (proto->payloadPosition == proto->buffer.payloadSize) { + proto->buffer.payload[proto->payload_position] = byte; + proto->payload_position++; + if (proto->payload_position == proto->buffer.payload_size) { /* Payload read - message received */ messageReceived(proto); } @@ -108,7 +108,7 @@ void protoConsume(protocol_t *proto, uint8_t byte) { } } -void protoSilence(protocol_t *proto) { +void proto_silence(protocol_t *proto) { if (proto->state != STATE_SYNC_1) { proto->state = STATE_SYNC_1; proto->errors++; -- cgit v1.2.1