From 7da0a5f7ecefbfc387e63190f34c0ffe2108cb83 Mon Sep 17 00:00:00 2001 From: Scott Powell Date: Tue, 4 Feb 2025 12:35:53 +1100 Subject: * new RX delays based on SNR --- src/helpers/StaticPoolPacketManager.cpp | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) (limited to 'src/helpers/StaticPoolPacketManager.cpp') diff --git a/src/helpers/StaticPoolPacketManager.cpp b/src/helpers/StaticPoolPacketManager.cpp index ddf53232..3cd0906e 100644 --- a/src/helpers/StaticPoolPacketManager.cpp +++ b/src/helpers/StaticPoolPacketManager.cpp @@ -57,7 +57,7 @@ void PacketQueue::add(mesh::Packet* packet, uint8_t priority, uint32_t scheduled _num++; } -StaticPoolPacketManager::StaticPoolPacketManager(int pool_size): unused(pool_size), send_queue(pool_size) { +StaticPoolPacketManager::StaticPoolPacketManager(int pool_size): unused(pool_size), send_queue(pool_size), rx_queue(pool_size) { // load up our unusued Packet pool for (int i = 0; i < pool_size; i++) { unused.add(new mesh::Packet(), 0, 0); @@ -95,3 +95,10 @@ mesh::Packet* StaticPoolPacketManager::getOutboundByIdx(int i) { mesh::Packet* StaticPoolPacketManager::removeOutboundByIdx(int i) { return send_queue.removeByIdx(i); } + +void StaticPoolPacketManager::queueInbound(mesh::Packet* packet, uint32_t scheduled_for) { + // TODO +} +mesh::Packet* StaticPoolPacketManager::getNextInbound(uint32_t now) { + return NULL; // TODO +} -- cgit v1.2.3-70-g09d2