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

There are bugs or either timing is off for my test

This commit is contained in:
Tristan B. Velloza Kildaire 2022-03-18 15:54:54 +02:00
parent 20ec129f69
commit e65459633c
1 changed files with 15 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
source/tasky/engine.d
View File

@ -91,7 +91,10 @@ public final class Engine : Thread
// data.getData() // data.getData()
// evEngine.push // evEngine.push
writeln("Queue just dequeued from: ", descID, " ", tQueue);
} }
@ -154,6 +157,8 @@ public final class Engine : Thread
ulong jobTypeDI = jobType.getDescriptorClass; ulong jobTypeDI = jobType.getDescriptorClass;
ulong job2C = 0;
/* Job type */ /* Job type */
Descriptor jobType2 = new class Descriptor { Descriptor jobType2 = new class Descriptor {
public override void handler(Event e) public override void handler(Event e)
@ -164,6 +169,8 @@ public final class Engine : Thread
writeln("OTHER event type"); writeln("OTHER event type");
TaskyEvent eT = cast(TaskyEvent)e; TaskyEvent eT = cast(TaskyEvent)e;
writeln(cast(string)eT.payload); writeln(cast(string)eT.payload);
// job2C++;
// assert(cmp(cast(string)eT.payload, ""))
} }
}; };
@ -192,15 +199,15 @@ public final class Engine : Thread
sleep(dur!("seconds")(2)); sleep(dur!("seconds")(2));
import tristanable.encoding : DataMessage, encodeForSend; import tristanable.encoding : DataMessage, encodeForSend;
DataMessage dMesg = new DataMessage(jobTypeDI, cast(byte[])"Hello1"); DataMessage dMesg = new DataMessage(jobTypeDI, cast(byte[])"Hello 1");
writeln("Server send: ", clientSocket.send(encodeForSend(dMesg))); writeln("Server send 1: ", clientSocket.send(encodeForSend(dMesg)));
dMesg = new DataMessage(jobTypeDI, cast(byte[])"Hello2"); dMesg = new DataMessage(jobTypeDI, cast(byte[])"Hello 2");
writeln("Server send: ", clientSocket.send(encodeForSend(dMesg))); writeln("Server send 2: ", clientSocket.send(encodeForSend(dMesg)));
dMesg = new DataMessage(jobTypeDI2, cast(byte[])"Hello3"); dMesg = new DataMessage(jobTypeDI2, cast(byte[])"Bye-bye! 3");
writeln("Server send: ", clientSocket.send(encodeForSend(dMesg))); writeln("Server send 3: ", clientSocket.send(encodeForSend(dMesg)));
dMesg = new DataMessage(jobTypeDI2, cast(byte[])"Hello4"); dMesg = new DataMessage(jobTypeDI2, cast(byte[])"Bye-bye! 4");
writeln("Server send: ", clientSocket.send(encodeForSend(dMesg))); writeln("Server send 4: ", clientSocket.send(encodeForSend(dMesg)));
} }
}; };