deuxyeux/RTNode-HeltecV4
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

v1.0.13: Fix path discovery starvation and remove redundant announce echo blocking

Browse Source 
Immediate PATH_RESPONSE for local clients: On ESP32, continuous TCP
backbone data can starve the jobs() loop for many seconds, causing
path discovery timeouts for local TCP clients. When a local client's
path request is satisfied by a cached announce, send the PATH_RESPONSE
immediately rather than queuing it for the next jobs() cycle.

Remove boundary-mode announce echo blocking: The boundary-specific
code that prevented backbone announces from overwriting LoRa paths
was redundant (the standard random_blob check already prevents echoes)
and harmful (it blocked TCP clients from learning backbone paths and
prevented correct transport routing for LINKREQUESTs).
This commit is contained in:
James L
2026-02-28 14:40:05 -05:00
parent 1122e9a0ee
commit f042dd5f71
2 changed files with 43 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

0
MICRORETICULUM_BUGS.md Normal file → Executable file
View File

62
lib/microReticulum/src/Transport.cpp
View File

@@ -2240,25 +2240,19 @@ static bool is_backbone_interface(const Interface& iface) {
should_add = true; should_add = true;
} }
if (should_add) { // NOTE: The boundary-mode announce echo blocking that was here
// BOUNDARY MODE: Prevent backbone echo from overwriting a local LoRa path // has been removed. The standard random_blob check above
#ifdef BOUNDARY_MODE // already prevents echoes (same blob = same announce bounced
{ // through backbone). Removing the boundary-specific blocking
auto existing_iter = _destination_table.find(packet.destination_hash()); // allows:
if (existing_iter != _destination_table.end()) { // 1. Local TCP clients to receive backbone announces for
DestinationEntry& existing = existing_iter->second; // destinations that also have LoRa paths.
Interface existing_iface = existing.receiving_interface(); // 2. The V3 destination table to contain the backbone path
bool existing_is_lora = !is_backbone_interface(existing_iface); // when it is equal-or-better, enabling correct transport
bool new_is_backbone = is_backbone_interface(packet.receiving_interface()); // routing for TCP client LINKREQUESTs.
if (existing_is_lora && new_is_backbone) { // LoRa-originated announces that arrive first will still be
DEBUG("BOUNDARY: Blocking backbone announce echo from overwriting local LoRa path for " + packet.destination_hash().toHex() // preferred (equal hops = first-arrival wins via random_blob),
+ " (existing " + std::to_string(existing._hops) + " hops via LoRa, new " + std::to_string(packet.hops()) + " hops via backbone)"); // until the next re-announce cycle changes the path.
should_add = false;
}
}
}
#endif
}
if (should_add) { if (should_add) {
double now = OS::time(); double now = OS::time();
@@ -3747,6 +3741,36 @@ will announce it.
); );
// CBA ACCUMULATES // CBA ACCUMULATES
_announce_table.insert({announce_packet.destination_hash(), announce_entry}); _announce_table.insert({announce_packet.destination_hash(), announce_entry});
// ESP32 FIX: For requests from local clients, send the
// PATH_RESPONSE immediately rather than waiting for the
// jobs() loop to process the announce_table entry. On the
// ESP32, continuous TCP backbone data can starve the jobs
// loop for many seconds, causing path discovery timeouts.
if (is_from_local_client) {
Identity imm_identity(Identity::recall(announce_packet.destination_hash()));
if (imm_identity) {
Destination imm_destination(imm_identity, Type::Destination::OUT, Type::Destination::SINGLE, announce_packet.destination_hash());
Packet imm_packet(
imm_destination,
attached_interface,
announce_packet.data(),
Type::Packet::ANNOUNCE,
Type::Packet::PATH_RESPONSE,
Type::Transport::TRANSPORT,
Type::Packet::HEADER_2,
_identity.hash(),
true,
announce_packet.context_flag()
);
imm_packet.hops(announce_hops);
imm_packet.send();
DEBUG("DIAG: PATH-RESP immediate send for " + announce_packet.destination_hash().toHex().substr(0,8) + " hops=" + std::to_string(announce_hops) + " to " + attached_interface.toString());
// Remove from announce_table since we already sent it
_announce_table.erase(announce_packet.destination_hash());
}
}
} }
} }
} }