From 295d9ff672ee3f92bb359524374d68eae4342623 Mon Sep 17 00:00:00 2001 From: "Tristan B. Kildaire" Date: Sat, 19 Mar 2022 12:29:04 +0200 Subject: [PATCH] Removed TODO Don't let socket close --- source/tasky/engine.d | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/source/tasky/engine.d b/source/tasky/engine.d index 3bd76a7..af160f5 100644 --- a/source/tasky/engine.d +++ b/source/tasky/engine.d @@ -72,6 +72,8 @@ public final class Engine : Thread foreach(Queue tQueue; tQueues) { + // writeln("Check queue: ", tQueue); + /* Descriptor ID */ ulong descID = tQueue.getTag(); @@ -128,8 +130,6 @@ public final class Engine : Thread /* Add a signal handler that handles said descriptor ID */ evEngine.addSignalHandler(desc); - /* TODO: Tristanable queue addition here */ - /* Create a new queue for this Job */ Queue tQueue = new Queue(desc.getDescriptorClass()); @@ -209,6 +209,12 @@ public final class Engine : Thread dMesg = new DataMessage(jobTypeDI2, cast(byte[])"Bye-bye! 4"); writeln("Server send 4: ", clientSocket.send(encodeForSend(dMesg))); + + while(true) + { + + } + } };