niklas/cc-haxe
1
0
Fork 0
Code Issues 13 Pull Requests Projects Releases Wiki Activity

added onNewNeigbor

Browse Source
This commit is contained in:
Djeeberjr 2022-02-22 01:47:55 +01:00
parent fd745d623c
commit e2431666e1
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/kernel/net/Net.hx
View File

@ -1,5 +1,7 @@
package kernel.net; package kernel.net;
using tink.CoreApi;
import kernel.peripherals.Peripherals.Peripheral; import kernel.peripherals.Peripherals.Peripheral;
import kernel.Log; import kernel.Log;
import kernel.KernelEvents; import kernel.KernelEvents;
@ -19,8 +21,12 @@ using util.Extender.LambdaExtender;
class Net { class Net {
public static var instance:Net; public static var instance:Net;
public final onNewNeigbor: Signal<Int>;
private final onNewNeigborTrigger: SignalTrigger<Int> = Signal.trigger();
@:allow(kernel.Init) @:allow(kernel.Init)
private function new() { private function new() {
onNewNeigbor = onNewNeigborTrigger.asSignal();
KernelEvents.instance.onModemMessage.handle(params -> { KernelEvents.instance.onModemMessage.handle(params -> {
var pack:Package = { var pack:Package = {
fromID: params.replyChannel, fromID: params.replyChannel,
@ -108,6 +114,7 @@ class Net {
private function addRoute(toID:Int, addr:String) { private function addRoute(toID:Int, addr:String) {
Log.debug("Added new route to " + toID + " via " + addr); Log.debug("Added new route to " + toID + " via " + addr);
this.onNewNeigborTrigger.trigger(toID);
routingTable.set(toID, allModems.find(item -> item.addr == addr)); routingTable.set(toID, allModems.find(item -> item.addr == addr));
} }