From c7298f5ea6dc3bf66c1b841e673d3d446d79508c Mon Sep 17 00:00:00 2001
From: Smooth Operator <github@andy.disruptek.com>
Date: Sun, 27 Oct 2024 09:01:41 -0400
Subject: [PATCH] impl clear for safe-mode

---
 insideout/mailboxes.nim | 22 +++++++++++++++++++---
 1 file changed, 19 insertions(+), 3 deletions(-)

diff --git a/insideout/mailboxes.nim b/insideout/mailboxes.nim
index 5536ca9..10513e1 100644
--- a/insideout/mailboxes.nim
+++ b/insideout/mailboxes.nim
@@ -511,11 +511,27 @@ proc resume*[T](mail: Mailbox[T]) =
   if disable(mail[].state, Paused):
     checkWake wakeMask(mail[].state, <<!Paused)
 
+proc clear*[T](mail: var MailboxObj[T]) =
+  when insideoutSafeMode:
+    withRLock mail.lock:
+      while not mail.list.head.isNil:
+        if mail.list.head.next == mail.list.head:  # last item
+          reset mail.list.head.next
+          reset mail.list.head
+        else:
+          var node = mail.list.head
+          mail.list.head = node.next
+          if mail.list.tail.next == node:
+            mail.list.tail.next = mail.list.head
+          reset node
+  else:
+    if not mail.queue.isNil:
+      while not pop(mail.queue).isNil:
+        discard
+
 proc clear*[T](mail: Mailbox[T]) =
   when T isnot void:
-    if not mail[].queue.isNil:
-      while not pop(mail[].queue).isNil:
-        discard
+    clear mail[]
 
 proc waitForEmpty*[T](mail: Mailbox[T]) =
   assert not mail.isNil