diff --git a/source/tristanable/manager.d b/source/tristanable/manager.d index 379598c..aae75a6 100644 --- a/source/tristanable/manager.d +++ b/source/tristanable/manager.d @@ -43,18 +43,24 @@ public final class Manager private bool isAlive; + private bool onRecvQueue; + + /** * Constructs a new Manager with the given * endpoint Socket * */ - this(Socket socket, Duration timeOut = dur!("msecs")(100), bool newSys = false) + this(Socket socket, Duration timeOut = dur!("msecs")(100), bool newSys = false, bool onRecvQueue = false) { /* TODO: Make sure the socket is in STREAM mode */ /* Set the socket */ this.socket = socket; + /* Set whether this should have on-receive queue funtionality */ + this.onRecvQueue = onRecvQueue; + /* Initialize the queues mutex */ queuesLock = new Mutex(); @@ -74,6 +80,11 @@ public final class Manager watcher.start(); } + public bool isOnRecvQueue() + { + return onRecvQueue; + } + public Queue getQueue(ulong tag) { Queue matchingQueue;