mirror of
https://github.com/meshtastic/firmware.git
synced 2025-12-21 10:12:50 +00:00
8a79663fa0
Track packet pointers in vector. Priority maintained using: push_heap, pop_heap, make_heap, and sort_heap.
33 lines
778 B
C++
33 lines
778 B
C++
#pragma once
|
|
|
|
#include "MeshTypes.h"
|
|
|
|
#include <assert.h>
|
|
#include <queue>
|
|
|
|
|
|
/**
|
|
* A priority queue of packets
|
|
*/
|
|
class MeshPacketQueue
|
|
{
|
|
size_t maxLen;
|
|
std::vector<MeshPacket *> queue;
|
|
|
|
/** Replace a lower priority package in the queue with 'mp' (provided there are lower pri packages). Return true if replaced. */
|
|
bool replaceLowerPriorityPacket(MeshPacket *mp);
|
|
|
|
public:
|
|
MeshPacketQueue(size_t _maxLen);
|
|
|
|
/** enqueue a packet, return false if full */
|
|
bool enqueue(MeshPacket *p);
|
|
|
|
/** return true if the queue is empty */
|
|
bool empty();
|
|
|
|
MeshPacket *dequeue();
|
|
|
|
/** Attempt to find and remove a packet from this queue. Returns the packet which was removed from the queue */
|
|
MeshPacket *remove(NodeNum from, PacketId id);
|
|
}; |