fly/fgdata
1
0
Fork 0
Code Activity

Emesary: add new method and tidy up diagnostics.

Browse source
This commit is contained in:
Richard Harrison 2018-07-28 00:33:38 +02:00
parent 2322d0dbe8
commit ee9f10cc03
2 changed files with 9 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
Nasal/emesary.nas
View file

@ -53,7 +53,10 @@ var Transmitter =
{ {
append(me.Recipients, recipient); append(me.Recipients, recipient);
}, },
DeleteAllRecipients: func
{
me.Recipients = [];
},
# Stops a recipient from receiving notifications from this transmitter. # Stops a recipient from receiving notifications from this transmitter.
DeRegister: func(todelete_recipient) DeRegister: func(todelete_recipient)
{ {
@ -95,6 +98,10 @@ var Transmitter =
# allows for usages such as access controls. # allows for usages such as access controls.
NotifyAll: func(message) NotifyAll: func(message)
{ {
if (message == nil){
print("Emesary: bad notification nil");
return Transmitter.ReceiptStatus_NotProcessed;
}
var return_status = Transmitter.ReceiptStatus_NotProcessed; var return_status = Transmitter.ReceiptStatus_NotProcessed;
foreach (var recipient; me.Recipients) foreach (var recipient; me.Recipients)
{ {

2
Nasal/emesary_mp_bridge.nas
View file

@ -90,7 +90,7 @@ var OutgoingMPBridge =
foreach(var n ; new_class.NotificationsToBridge) foreach(var n ; new_class.NotificationsToBridge)
{ {
print(" Outward bridge notifications of type --> ",n.NotificationType); print(" ",_ident," outwards bridge[",n,"] notifications of type --> ",n.NotificationType, " Id ",n.TypeId);
n.MessageIndex = OutgoingMPBridge.StartMessageIndex; n.MessageIndex = OutgoingMPBridge.StartMessageIndex;
new_class.NotificationsToBridge_Lookup[n.TypeId] = n; new_class.NotificationsToBridge_Lookup[n.TypeId] = n;
} }