mirror of https://github.com/deavmi/tasky.git
parent
e65459633c
commit
295d9ff672
|
@ -72,6 +72,8 @@ public final class Engine : Thread
|
||||||
|
|
||||||
foreach(Queue tQueue; tQueues)
|
foreach(Queue tQueue; tQueues)
|
||||||
{
|
{
|
||||||
|
// writeln("Check queue: ", tQueue);
|
||||||
|
|
||||||
/* Descriptor ID */
|
/* Descriptor ID */
|
||||||
ulong descID = tQueue.getTag();
|
ulong descID = tQueue.getTag();
|
||||||
|
|
||||||
|
@ -128,8 +130,6 @@ public final class Engine : Thread
|
||||||
/* Add a signal handler that handles said descriptor ID */
|
/* Add a signal handler that handles said descriptor ID */
|
||||||
evEngine.addSignalHandler(desc);
|
evEngine.addSignalHandler(desc);
|
||||||
|
|
||||||
/* TODO: Tristanable queue addition here */
|
|
||||||
|
|
||||||
/* Create a new queue for this Job */
|
/* Create a new queue for this Job */
|
||||||
Queue tQueue = new Queue(desc.getDescriptorClass());
|
Queue tQueue = new Queue(desc.getDescriptorClass());
|
||||||
|
|
||||||
|
@ -209,6 +209,12 @@ public final class Engine : Thread
|
||||||
dMesg = new DataMessage(jobTypeDI2, cast(byte[])"Bye-bye! 4");
|
dMesg = new DataMessage(jobTypeDI2, cast(byte[])"Bye-bye! 4");
|
||||||
writeln("Server send 4: ", clientSocket.send(encodeForSend(dMesg)));
|
writeln("Server send 4: ", clientSocket.send(encodeForSend(dMesg)));
|
||||||
|
|
||||||
|
|
||||||
|
while(true)
|
||||||
|
{
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue