Added notifcation system
This commit is contained in:
parent
47565b5692
commit
a0bb8fd477
|
@ -2,6 +2,7 @@ module tristanable.watcher;
|
||||||
|
|
||||||
import tristanable.manager : Manager;
|
import tristanable.manager : Manager;
|
||||||
import tristanable.request : Request;
|
import tristanable.request : Request;
|
||||||
|
import tristanable.notifications : NotificationReply;
|
||||||
import std.socket : Socket;
|
import std.socket : Socket;
|
||||||
import core.thread : Thread;
|
import core.thread : Thread;
|
||||||
import bmessage : receiveMessage;
|
import bmessage : receiveMessage;
|
||||||
|
@ -91,7 +92,14 @@ public final class Watcher : Thread
|
||||||
*/
|
*/
|
||||||
else if(manager.isReservedTag(receivedTag))
|
else if(manager.isReservedTag(receivedTag))
|
||||||
{
|
{
|
||||||
/* TODO: Implement me */
|
/* Lock the notification queue */
|
||||||
|
manager.lockNotificationQueue();
|
||||||
|
|
||||||
|
/* Create the NotificationReply */
|
||||||
|
NotificationReply notifyReply = new NotificationReply(receivedTag, receivedMessage);
|
||||||
|
|
||||||
|
/* Unlock the notification queue */
|
||||||
|
manager.unlockNotificationQueue();
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
|
|
Loading…
Reference in New Issue