mirror of
https://github.com/meshtastic/firmware.git
synced 2025-08-12 16:25:16 +00:00
b0fe5ef8ba
* Initial commit of a fuzzer for Meshtastic. * Use a max of 5 for the phone queues * Only write files to the temp dir * Limitless queue + fuzzer = lots of ram :) * Use $PIO_ENV for path to program * spelling: s/is/to/ * Use loopCanSleep instead of a lock in Router * realHardware allows full use of a CPU core * Ignore checkov CKV_DOCKER_2 & CKV_DOCKER_3 * Add Atak seed * Fix lint issues in build.sh * Use exception to exit from portduino_main * Separate build & source files into $WORK & $SRC * Use an ephemeral port for the API server * Include CXXFLAGS in the link step * Read all shared libraries * Use a separate work directory for each sanitizer --------- Co-authored-by: Ben Meadors <benmmeadors@gmail.com>
50 lines
1.3 KiB
C++
50 lines
1.3 KiB
C++
#pragma once
|
|
|
|
#include "Router.h"
|
|
#include <unordered_set>
|
|
|
|
/// We clear our old flood record 10 minutes after we see the last of it
|
|
#ifdef FUZZING_BUILD_MODE_UNSAFE_FOR_PRODUCTION
|
|
#define FLOOD_EXPIRE_TIME (5 * 1000L) // Don't allow too many packets to accumulate when fuzzing.
|
|
#else
|
|
#define FLOOD_EXPIRE_TIME (10 * 60 * 1000L)
|
|
#endif
|
|
|
|
/**
|
|
* A record of a recent message broadcast
|
|
*/
|
|
struct PacketRecord {
|
|
NodeNum sender;
|
|
PacketId id;
|
|
uint32_t rxTimeMsec; // Unix time in msecs - the time we received it
|
|
|
|
bool operator==(const PacketRecord &p) const { return sender == p.sender && id == p.id; }
|
|
};
|
|
|
|
class PacketRecordHashFunction
|
|
{
|
|
public:
|
|
size_t operator()(const PacketRecord &p) const { return (std::hash<NodeNum>()(p.sender)) ^ (std::hash<PacketId>()(p.id)); }
|
|
};
|
|
|
|
/**
|
|
* This is a mixin that adds a record of past packets we have seen
|
|
*/
|
|
class PacketHistory
|
|
{
|
|
private:
|
|
std::unordered_set<PacketRecord, PacketRecordHashFunction> recentPackets;
|
|
|
|
void clearExpiredRecentPackets(); // clear all recentPackets older than FLOOD_EXPIRE_TIME
|
|
|
|
public:
|
|
PacketHistory();
|
|
|
|
/**
|
|
* Update recentBroadcasts and return true if we have already seen this packet
|
|
*
|
|
* @param withUpdate if true and not found we add an entry to recentPackets
|
|
*/
|
|
bool wasSeenRecently(const meshtastic_MeshPacket *p, bool withUpdate = true);
|
|
};
|