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 *