From d89fe0fd060ced2b8f1d259a2348904eaa8bcf53 Mon Sep 17 00:00:00 2001
From: "Tristan B. Velloza Kildaire" <deavmi@redxen.eu>
Date: Thu, 9 Mar 2023 15:47:52 +0200
Subject: [PATCH] Sender

- Added `sq` (send queue append) method

Receive

- Added `rq` (receive queue append) method
---
 source/birchwood/client/receiver.d | 15 +++++++++++++++
 source/birchwood/client/sender.d   | 16 ++++++++++++++++
 2 files changed, 31 insertions(+)

diff --git a/source/birchwood/client/receiver.d b/source/birchwood/client/receiver.d
index 95b54ff..eab99b9 100644
--- a/source/birchwood/client/receiver.d
+++ b/source/birchwood/client/receiver.d
@@ -50,6 +50,21 @@ public final class ReceiverThread : Thread
         this.recvQueueLock = new Mutex();
     }
 
+    // TODO: Rename to `receiveQ`
+    public void rq(ubyte[] encodedMessage)
+    {
+        /* Lock queue */
+        recvQueueLock.lock();
+
+        /* Add to queue */
+        recvQueue.insertAfter(recvQueue[], encodedMessage);
+
+        /* Unlock queue */
+        recvQueueLock.unlock();
+
+        // TODO: Add libsnooze event wake up
+    }
+
     /** 
      * The receive queue worker function
      *
diff --git a/source/birchwood/client/sender.d b/source/birchwood/client/sender.d
index 773be68..8425e0e 100644
--- a/source/birchwood/client/sender.d
+++ b/source/birchwood/client/sender.d
@@ -46,6 +46,22 @@ public final class SenderThread : Thread
         this.sendQueueLock = new Mutex();
     }
 
+    // TODO: Rename to `sendQ`
+    public void sq(ubyte[] encodedMessage)
+    {
+        /* Lock queue */
+        sendQueueLock.lock();
+
+        /* Add to queue */
+        sendQueue.insertAfter(sendQueue[], encodedMessage);
+
+        /* Unlock queue */
+        sendQueueLock.unlock();
+
+        // TODO: Add libsnooze event wake up
+    }
+
+
     /** 
      * The send queue worker function
      *