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) + { + + } + } };