nostr works on esp32 but sometimes fragmentation and thread limits

ThomasFarstrike · ThomasFarstrike · commit ef4a6e2d8a54 · 2025-05-20T08:32:37.000+02:00
diff --git a/internal_filesystem/lib/threading.py b/internal_filesystem/lib/threading.py
@@ -12,6 +12,7 @@ def start(self):
         # In MicroPython, _thread.start_new_thread doesn't support daemon threads directly
         # We store the daemon attribute for compatibility, but it may not affect termination
         #_thread.stack_size(32*1024)
+        _thread.stack_size(12*1024)
         _thread.start_new_thread(self.run, ())
 
     def run(self):
diff --git a/internal_filesystem/lib/websocket_nostr_receive.py b/internal_filesystem/lib/websocket_nostr_receive.py
@@ -37,15 +37,12 @@ def printevents():
     print("relaymanager subscribing")
     relay_manager.add_subscription(subscription_id, filters)
     time.sleep(3) # allow the connections to open
-    
     print("opening connections") # after this, CPU usage goes high and stays there
     relay_manager.open_connections({"cert_reqs": ssl.CERT_NONE}) # NOTE: This disables ssl certificate verification
     time.sleep(10) # allow the connections to open
-    
     print("publishing:")
     relay_manager.publish_message(message)
     time.sleep(10) # allow the messages to send
-    
     print("printing events:")
     #while relay_manager.message_pool.has_events():
     for _ in range(10):
@@ -70,13 +67,15 @@ def printevents():
 # [DEBUG 408724546] Connecting to wss://relay.damus.io
 # [DEBUG 408724547] Using SSL with no certificate verification
 # 24KB is fine
-_thread.stack_size(18*1024)
-_thread.start_new_thread(printevents, ())
-#printevents()
+# somehow, if I run this in a thread, I get: can't create thread" at File "/lib/nostr/relay_manager.py", line 48, in open_connections
+# tried stack sizes from 18KB up to 32KB
+#_thread.stack_size(48*1024)
+#_thread.start_new_thread(printevents, ())
+printevents()
 
 
-import gc
-for _ in range(50):
-    collect = gc.collect()
-    print(f"MEMFREE: {gc.mem_free()}")
-    time.sleep(1)
+#import gc
+#for _ in range(50):
+#    collect = gc.collect()
+#    print(f"MEMFREE: {gc.mem_free()}")
+#    time.sleep(1)
