From 01417f6fd18263adfcc1172ba2caf1dbbecce8d7 Mon Sep 17 00:00:00 2001
From: Eric Severance <esev@esev.com>
Date: Wed, 8 Jan 2025 09:46:25 -0800
Subject: [PATCH] Limitless queue + fuzzer = lots of ram :)

---
 src/mesh/TypedQueue.h | 15 ++++++++++++---
 1 file changed, 12 insertions(+), 3 deletions(-)

diff --git a/src/mesh/TypedQueue.h b/src/mesh/TypedQueue.h
index f7d016f10..47d7200a5 100644
--- a/src/mesh/TypedQueue.h
+++ b/src/mesh/TypedQueue.h
@@ -74,11 +74,17 @@ template <class T> class TypedQueue
 {
     std::queue<T> q;
     concurrency::OSThread *reader = NULL;
+    int maxElements;
 
   public:
-    explicit TypedQueue(int maxElements) {}
+    explicit TypedQueue(int _maxElements) : maxElements(_maxElements) {}
 
-    int numFree() { return 1; } // Always claim 1 free, because we can grow to any size
+    int numFree()
+    {
+        if (maxElements <= 0)
+            return 1; // Always claim 1 free, because we can grow to any size
+        return maxElements - numUsed();
+    }
 
     bool isEmpty() { return q.empty(); }
 
@@ -86,6 +92,9 @@ template <class T> class TypedQueue
 
     bool enqueue(T x, TickType_t maxWait = portMAX_DELAY)
     {
+        if (numFree() <= 0)
+            return false;
+
         if (reader) {
             reader->setInterval(0);
             concurrency::mainDelay.interrupt();
@@ -112,4 +121,4 @@ template <class T> class TypedQueue
 
     void setReader(concurrency::OSThread *t) { reader = t; }
 };
-#endif
+#endif
\ No newline at end of file