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

Don't go further if the receive failed

This commit is contained in:
Tristan B. Kildaire 2020-09-28 20:43:46 +02:00
parent b0b7f69778
commit 90835f3c97
1 changed files with 46 additions and 40 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

86
source/tristanable/watcher.d
View File

@ -58,53 +58,59 @@ public final class Watcher : Thread
/* Receive a message */
bool recvStatus = receiveMessage(endpoint, receivedPayload);
/* TODO: Status check */
/* Only continue if the receive was a success */
if(recvStatus)
{
/* Fetch the `tag` */
receivedTag = *(cast(ulong*)receivedPayload.ptr);
/* Fetch the `tag` */
receivedTag = *(cast(ulong*)receivedPayload.ptr);
/* Fetch the `data` */
receivedMessage = receivedPayload[8..receivedPayload.length];
/* Fetch the `data` */
receivedMessage = receivedPayload[8..receivedPayload.length];
/* Lock the queue for reading */
manager.lockQueue();
/* Lock the queue for reading */
manager.lockQueue();
/* Get the queue */
Request[] currentQueue = manager.getQueue();
/* Get the queue */
Request[] currentQueue = manager.getQueue();
/* Check to see if this is a tag we are awaiting */
bool foundTag = manager.isValidTag(receivedTag);
ulong requestPosition = manager.getTagPosition(receivedTag);
/* Check to see if this is a tag we are awaiting */
bool foundTag = manager.isValidTag(receivedTag);
ulong requestPosition = manager.getTagPosition(receivedTag);
/**
* Check if the tag was found
*
* This only accounts for tags requested
*/
if(foundTag)
{
/* Fulfill the request */
currentQueue[requestPosition].fulfill(receivedMessage);
}
/**
* Check if the tag was reservd
*/
else if(manager.isReservedTag(receivedTag))
{
/* Create the NotificationReply */
NotificationReply notifyReply = new NotificationReply(receivedTag, receivedMessage);
/**
* Check if the tag was found
*
* This only accounts for tags requested
*/
if(foundTag)
{
/* Fulfill the request */
currentQueue[requestPosition].fulfill(receivedMessage);
}
/**
* Check if the tag was reservd
*/
else if(manager.isReservedTag(receivedTag))
{
/* Create the NotificationReply */
NotificationReply notifyReply = new NotificationReply(receivedTag, receivedMessage);
/* Add the notification */
manager.addNotification(notifyReply);
}
else
{
/* TODO: */
}
/* Add the notification */
manager.addNotification(notifyReply);
}
else
{
/* TODO: */
}
/* Unlock the queue */
manager.unlockQueue();
/* Unlock the queue */
manager.unlockQueue();
}
else
{
/* TODO: Add error handling */
}
}
}
}