|
| 1 | +From ab2fc76ed60e64f52cb6379ffdf4a04691af658d Mon Sep 17 00:00:00 2001 |
| 2 | +From: Antonio cuadros <acuadros1995@gmail.com> |
| 3 | +Date: Mon, 27 Sep 2021 09:21:33 +0200 |
| 4 | +Subject: [PATCH] Add tx queue utilities |
| 5 | + |
| 6 | +--- |
| 7 | + src/hal/interface/radiolink.h | 3 ++- |
| 8 | + src/hal/src/radiolink.c | 10 ++++++++++ |
| 9 | + 2 files changed, 12 insertions(+), 1 deletion(-) |
| 10 | + |
| 11 | +diff --git a/src/hal/interface/radiolink.h b/src/hal/interface/radiolink.h |
| 12 | +index 293c5c64..ad85e313 100644 |
| 13 | +--- a/src/hal/interface/radiolink.h |
| 14 | ++++ b/src/hal/interface/radiolink.h |
| 15 | +@@ -58,6 +58,7 @@ void radiolinkSyslinkDispatch(SyslinkPacket *slp); |
| 16 | + struct crtpLinkOperations * radiolinkGetLink(); |
| 17 | + bool radiolinkSendP2PPacketBroadcast(P2PPacket *p2pp); |
| 18 | + void p2pRegisterCB(P2PCallback cb); |
| 19 | +- |
| 20 | ++int linkGetFreeTxQueuePackets(void); |
| 21 | ++int linkResetTxQueuePackets(void); |
| 22 | + |
| 23 | + #endif //__RADIO_H__ |
| 24 | +diff --git a/src/hal/src/radiolink.c b/src/hal/src/radiolink.c |
| 25 | +index 738901f3..23d000b3 100644 |
| 26 | +--- a/src/hal/src/radiolink.c |
| 27 | ++++ b/src/hal/src/radiolink.c |
| 28 | +@@ -74,6 +74,16 @@ static bool radiolinkIsConnected(void) { |
| 29 | + return (xTaskGetTickCount() - lastPacketTick) < M2T(RADIO_ACTIVITY_TIMEOUT_MS); |
| 30 | + } |
| 31 | + |
| 32 | ++int linkGetFreeTxQueuePackets(void) |
| 33 | ++{ |
| 34 | ++ return (RADIOLINK_TX_QUEUE_SIZE - uxQueueMessagesWaiting(txQueue)); |
| 35 | ++} |
| 36 | ++ |
| 37 | ++int linkResetTxQueuePackets(void) |
| 38 | ++{ |
| 39 | ++ return xQueueReset(txQueue); |
| 40 | ++} |
| 41 | ++ |
| 42 | + static struct crtpLinkOperations radiolinkOp = |
| 43 | + { |
| 44 | + .setEnable = radiolinkSetEnable, |
| 45 | +-- |
| 46 | +2.25.1 |
| 47 | + |
0 commit comments