diff options
| author | Scott Powell <sqij@protonmail.com> | 2025-02-04 12:35:53 +1100 |
|---|---|---|
| committer | Scott Powell <sqij@protonmail.com> | 2025-02-04 12:35:53 +1100 |
| commit | 7da0a5f7ecefbfc387e63190f34c0ffe2108cb83 (patch) | |
| tree | cc18cbdfd07cb325597069ea320e955733208031 /src/helpers/StaticPoolPacketManager.cpp | |
| parent | 29e62b9ce23a5c1de3d88d73e2c2730409f9c761 (diff) | |
* new RX delays based on SNR
Diffstat (limited to 'src/helpers/StaticPoolPacketManager.cpp')
| -rw-r--r-- | src/helpers/StaticPoolPacketManager.cpp | 9 |
1 files changed, 8 insertions, 1 deletions
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 +} |
