Repair error in monitoring of mDNS retractions
This commit is contained in:
parent
7ea4531303
commit
bbf691c9b5
|
@ -181,6 +181,14 @@ spawn named 'uplinkSelection' {
|
||||||
assert P.Proposal(managementScope, link);
|
assert P.Proposal(managementScope, link);
|
||||||
};
|
};
|
||||||
|
|
||||||
|
const monitor_mDNS_retraction = (peer, retracted_callback) => {
|
||||||
|
if (OverlayNode.isClassOf(peer)) {
|
||||||
|
stop on retracted Peer(overlayId, OverlayNode._id(peer), _, _) {
|
||||||
|
retracted_callback();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
const START = () => {
|
const START = () => {
|
||||||
react {
|
react {
|
||||||
// Wait for stability:
|
// Wait for stability:
|
||||||
|
@ -202,7 +210,7 @@ spawn named 'uplinkSelection' {
|
||||||
assertSelectedUplink(link);
|
assertSelectedUplink(link);
|
||||||
const timeout = futureTime(15000);
|
const timeout = futureTime(15000);
|
||||||
stop on asserted TimeLaterThan(timeout) CONNECT(peer);
|
stop on asserted TimeLaterThan(timeout) CONNECT(peer);
|
||||||
stop on retracted peer CONNECT(null);
|
monitor_mDNS_retraction(peer, () => CONNECT(null));
|
||||||
stop on asserted P.Envelope(managementScope, Federation.UplinkConnected(link)) {
|
stop on asserted P.Envelope(managementScope, Federation.UplinkConnected(link)) {
|
||||||
MAINTAIN(peer, link);
|
MAINTAIN(peer, link);
|
||||||
}
|
}
|
||||||
|
@ -214,7 +222,7 @@ spawn named 'uplinkSelection' {
|
||||||
react {
|
react {
|
||||||
assertSelectedUplink(link);
|
assertSelectedUplink(link);
|
||||||
assert C.ToServer(C.Loopback(overlayId), OverlayLink(OverlayNode(localId), peer));
|
assert C.ToServer(C.Loopback(overlayId), OverlayLink(OverlayNode(localId), peer));
|
||||||
stop on retracted peer CONNECT(null);
|
monitor_mDNS_retraction(peer, () => CONNECT(null));
|
||||||
stop on retracted P.Envelope(managementScope, Federation.UplinkConnected(link)) {
|
stop on retracted P.Envelope(managementScope, Federation.UplinkConnected(link)) {
|
||||||
CONNECT(peer);
|
CONNECT(peer);
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue