mirror of
https://github.com/deavmi/birchwood
synced 2024-09-19 17:43:20 +02:00
Sender
- Added `sq` (send queue append) method Receive - Added `rq` (receive queue append) method
This commit is contained in:
parent
b5e1b4065f
commit
d89fe0fd06
@ -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
|
||||
*
|
||||
|
@ -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
|
||||
*
|
||||
|
Loading…
Reference in New Issue
Block a user