dandri/ZephCore
1
0
Fork 0
mirror of https://github.com/liquidraver/ZephCore.git synced 2026-09-02 10:33:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

merge everything important up until d05d6abab8b52c0f20a0f85a0939c74bc762b4ad meschore/dev

Browse Source
This commit is contained in:
liquidraver
2026-02-22 13:41:57 +01:00
parent b6bc46b921
commit 73222600b2
16 changed files with 120 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files
zephcore/src/StaticPoolPacketManager.cpp
+9 -4
View File
@@ -65,12 +65,13 @@ struct PacketQueue {
return item;
}
void add(Packet *packet, uint8_t priority, uint32_t scheduled_for) {
if (_num >= QUEUE_SIZE) return;
bool add(Packet *packet, uint8_t priority, uint32_t scheduled_for) {
if (_num >= QUEUE_SIZE) return false;
_table[_num] = packet;
_pri_table[_num] = priority;
_schedule_table[_num] = scheduled_for;
_num++;
return true;
}
int count() const { return _num; }
@@ -104,7 +105,9 @@ void StaticPoolPacketManager::free(Packet *packet)
void StaticPoolPacketManager::queueOutbound(Packet *packet, uint8_t priority, uint32_t scheduled_for)
{
_send_queue.add(packet, priority, scheduled_for);
if (!_send_queue.add(packet, priority, scheduled_for)) {
free(packet);
}
}
Packet *StaticPoolPacketManager::getNextOutbound(uint32_t now)
@@ -134,7 +137,9 @@ Packet *StaticPoolPacketManager::removeOutboundByIdx(int i)
void StaticPoolPacketManager::queueInbound(Packet *packet, uint32_t scheduled_for)
{
_rx_queue.add(packet, 0, scheduled_for);
if (!_rx_queue.add(packet, 0, scheduled_for)) {
free(packet);
}
}
Packet *StaticPoolPacketManager::getNextInbound(uint32_t now)