deavmi/tristanable
deavmi
/
tristanable
mirror of https://github.com/deavmi/tristanable.git
1
0
Fork 0
Code Issues 2 Projects Releases Wiki Activity

Expose new system architetcure to users via Manager constructor, however default to disabled

This commit is contained in:
Tristan B. Velloza Kildaire 2022-05-17 13:54:21 +02:00
parent 7de5d00c60
commit 6613d92908
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
source/tristanable/manager.d
View File

@ -4,6 +4,7 @@ import std.socket : Socket;
import core.sync.mutex : Mutex;
import bmessage : bSendMessage = sendMessage;
import tristanable.queue : Queue;
import core.thread : Thread, Duration, dur;
import tristanable.watcher;
import std.container.dlist;
import tristanable.exceptions;
@ -46,7 +47,7 @@ public final class Manager
* endpoint Socket
*
*/
this(Socket socket)
this(Socket socket, Duration timeOut = dur!("msecs")(100), bool newSys = false)
{
/* TODO: Make sure the socket is in STREAM mode */
@ -57,7 +58,7 @@ public final class Manager
queuesLock = new Mutex();
/* Initialize the watcher */
watcher = new Watcher(this, socket);
watcher = new Watcher(this, socket, timeOut, newSys);
}
public Queue getQueue(ulong tag)