WIP: reserved tags/notifcation system

source/tristanable/NotificationReply.d

@@ -18,5 +18,22 @@ module tristanable.notifications;
 
 public class NotificationReply
 {
-	
+	private ulong tag;
+	private byte[] data;
+
+	this(ulong tag, byte[] data)
+	{
+		this.tag = tag;
+		this.data = data;
+	}
+
+	public byte[] getData()
+	{
+		return data;
+	}
+
+	public ulong getTag()
+	{
+		return tag;
+	}
 }

source/tristanable/manager.d

@@ -40,6 +40,11 @@ public final class Manager
     */
     private Mutex queueMutex;
 
+    /**
+    * The notification queue mutex
+    */
+    private Mutex notificationMutex;
+
     /**
     * The remote host
     */
@@ -64,6 +69,9 @@ public final class Manager
         /* Initialize the `requestQueue` mutex */
         queueMutex = new Mutex();
 
+        /* Initialize the `notificationQueue` mutex */
+        notificationMutex = new Mutex();
+
         /* Start the watcher */
         watcher.start();
 
@@ -216,6 +224,36 @@ public final class Manager
         queueMutex.unlock();
     }
 
+    public void lockNotificationQueue()
+    {
+        notificationMutex.lock();
+    }
+
+    public void unlockNotificationQueue()
+    {
+        notificationMutex.unlock();
+    }
+
+    public NotificationReply[] popNotifications()
+    {
+    	/* The notifications at this moment */
+    	NotificationReply[] currentNotificationSet;
+    	
+    	/* Lock the notification queue */
+    	lockNotificationQueue();
+
+		/* Copy the current notifications */
+		currentNotificationSet = notificationQueue;
+
+    	/* Empty the notification list */
+    	notificationQueue.length = 0;
+
+    	/* Unlock the notification queue */
+    	unlockNotificationQueue();
+
+    	return currentNotificationSet;
+    }
+
 	public void reserveTag(ulong tag)
 	{
 		reservedTags ~= tag;