meshtastic/Meshtastic-Android
1
0
Fork 0
mirror of https://github.com/meshtastic/Meshtastic-Android.git synced 2026-04-20 22:23:37 +00:00
Code Issues Projects Releases Packages Wiki Activity

refactor: handle QueueStatus not responding under load

Browse source 
workaround for when the mesh is busy, radios fail to respond with `QueueStatus` and acknowledge sent packets.
- wait until radio queue is free or timeout, always assume sent packets went through;
- never resend, just timeout and move on to the next packet when there is no `QueueStatus` response.
This commit is contained in:
andrekir 2023-10-19 17:12:08 -03:00
parent 47bc9218dc
commit f0f4f44915
1 changed files with 5 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

16
app/src/main/java/com/geeksville/mesh/service/MeshService.kt
View file

@ -833,23 +833,17 @@ class MeshService : Service(), Logging {
queueJob = serviceScope.handledLaunch {
debug("packet queueJob started")
while (connectionState == ConnectionState.CONNECTED) {
var retryCount = 0
// take the first packet from the queue head
val packet = queuedPackets.poll() ?: break
while (retryCount < 3) try {
try {
// send packet to the radio and wait for response
val response = sendPacket(packet)
debug("queueJob packet id=${packet.id.toUInt()} waiting (retry $retryCount)")
@Suppress("BlockingMethodInNonBlockingContext")
val success = response.get(45, TimeUnit.SECONDS)
debug("queueJob packet id=${packet.id.toUInt()} waiting")
val success = response.get(2, TimeUnit.MINUTES)
debug("queueJob packet id=${packet.id.toUInt()} success $success")
if (success) break
retryCount++ // if send operation fails, retry
} catch (e: TimeoutException) {
debug("queueJob timeout waiting packet id=${packet.id.toUInt()}")
retryCount++ // if send operation fails, retry
}
if (retryCount >= 3) {
debug("queueJob packet id=${packet.id.toUInt()} timeout")
} catch (e: Exception) {
debug("queueJob packet id=${packet.id.toUInt()} failed")
}
}