From 051595a3778792a4427dfab03f6f68f6116a31b0 Mon Sep 17 00:00:00 2001 From: "Tristan B. Kildaire" Date: Sat, 1 Jan 2022 19:57:20 +0200 Subject: [PATCH] Added Mutexes --- source/dnetd/server.d | 12 +++++++++++- 1 file changed, 11 insertions(+), 1 deletion(-) diff --git a/source/dnetd/server.d b/source/dnetd/server.d index 6a97cb4..336d336 100644 --- a/source/dnetd/server.d +++ b/source/dnetd/server.d @@ -13,6 +13,7 @@ import dnetd.config : ConfigurationError, Configuration; import std.container.slist : SList; import dnetd.listeners.listeners : Listener; import dnetd.connection.connection : Connection; +import core.sync.mutex : Mutex; /** * Represents an instance of a dnet server @@ -26,13 +27,15 @@ public final class Server * Listeners */ private SList!(Listener) listeners; + private Mutex listenersMutex; /** * Connected clients and servers * * Inbound and outbound */ - private SList!(Connection) connections; + private SList!(Connection) conns; + private Mutex connsMutex; @@ -41,6 +44,13 @@ public final class Server { logger.log("Server instance '"~"PUT ID HERE"~"' starting up..."); this.config = config; + + /** + * Initialize all locks for data + * structures + */ + connsMutex = new Mutex(); + listeners = new Mutex(); } /* Rehash server configuration */