From 915b0ad115b62034ae9df422daa97f293df5af50 Mon Sep 17 00:00:00 2001
From: "Tristan B. Kildaire" <deavmi@redxen.eu>
Date: Sat, 19 Mar 2022 12:57:59 +0200
Subject: [PATCH] WIP: GOtta figure out timing and maybe hot loops and shit

---
 source/tasky/engine.d | 16 +++++++++++++++-
 1 file changed, 15 insertions(+), 1 deletion(-)

diff --git a/source/tasky/engine.d b/source/tasky/engine.d
index af160f5..1688c79 100644
--- a/source/tasky/engine.d
+++ b/source/tasky/engine.d
@@ -41,6 +41,8 @@ public final class Engine : Thread
 		tmanager = new Manager(socket);
 
 		start();
+
+		writeln("Task enegine finished init");
 	}
 
 	public class TaskyEvent : Event 
@@ -63,6 +65,8 @@ public final class Engine : Thread
 	*/
 	private void worker()
 	{
+		ulong got = 0;
+
 		while(true)
 		{
 			//writeln("WHITE BOY SUMMER");
@@ -70,6 +74,9 @@ public final class Engine : Thread
             /* TODO: Get all tristanable queues */
             Queue[] tQueues = tmanager.getQueues();
 
+
+			// writeln("Got: ", got);
+
             foreach(Queue tQueue; tQueues)
             {
 				// writeln("Check queue: ", tQueue);
@@ -95,9 +102,10 @@ public final class Engine : Thread
                     // evEngine.push
 
 					writeln("Queue just dequeued from: ", descID, " ", tQueue);
+
+					got++;
                 }
 				
-                
 
                 
 
@@ -106,6 +114,8 @@ public final class Engine : Thread
             /* TODO: Per each queue */
 
 			/* TODO: Yield away somehow */
+			import core.thread : dur;
+			sleep(dur!("msecs")(500));
 		}
 	}
 
@@ -198,6 +208,8 @@ public final class Engine : Thread
 
 				sleep(dur!("seconds")(2));
 
+				writeln("Server sending!!!!!!!!!!!");
+
 				import tristanable.encoding : DataMessage, encodeForSend;
 				DataMessage dMesg = new DataMessage(jobTypeDI, cast(byte[])"Hello 1");
 				writeln("Server send 1: ", clientSocket.send(encodeForSend(dMesg)));
@@ -231,6 +243,8 @@ public final class Engine : Thread
 		e.registerDescriptor(jobType);
 		e.registerDescriptor(jobType2);
 
+		writeln("TAsk client tests finished registration");
+
 
 		while(true)
 		{