aboutsummaryrefslogtreecommitdiff
path: root/src/helpers/StaticPoolPacketManager.cpp
diff options
context:
space:
mode:
authorScott Powell <sqij@protonmail.com>2025-02-04 12:35:53 +1100
committerScott Powell <sqij@protonmail.com>2025-02-04 12:35:53 +1100
commit7da0a5f7ecefbfc387e63190f34c0ffe2108cb83 (patch)
treecc18cbdfd07cb325597069ea320e955733208031 /src/helpers/StaticPoolPacketManager.cpp
parent29e62b9ce23a5c1de3d88d73e2c2730409f9c761 (diff)
* new RX delays based on SNR
Diffstat (limited to 'src/helpers/StaticPoolPacketManager.cpp')
-rw-r--r--src/helpers/StaticPoolPacketManager.cpp9
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
+}