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

feat: implement TCP interface reconnections

Browse source
This commit is contained in:
andrekir 2023-08-13 07:47:18 -03:00 • committed by Andre K
parent a76fb263bb
commit c94e20c42c
1 changed files with 29 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

37
app/src/main/java/com/geeksville/mesh/repository/radio/TCPInterface.kt
View file

@ -6,6 +6,7 @@ import com.geeksville.mesh.concurrent.handledLaunch
import com.geeksville.mesh.repository.usb.UsbRepository
import com.geeksville.mesh.util.Exceptions
import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.delay
import kotlinx.coroutines.withContext
import java.io.BufferedInputStream
import java.io.BufferedOutputStream
@ -29,8 +30,15 @@ class TCPInterface(service: RadioInterfaceService, private val address: String)
init {
registerFactory()
}
const val MAX_RETRIES_ALLOWED = Int.MAX_VALUE
const val MIN_BACKOFF_MILLIS = 1 * 1000L // 1 second
const val MAX_BACKOFF_MILLIS = 5 * 60 * 1000L // 5 minutes
}
private var retryCount = 1
private var backoffDelay = MIN_BACKOFF_MILLIS
private var socket: Socket? = null
private lateinit var outStream: OutputStream
@ -58,14 +66,24 @@ class TCPInterface(service: RadioInterfaceService, private val address: String)
override fun connect() {
service.serviceScope.handledLaunch {
try {
startConnect()
} catch (ex: IOException) {
errormsg("IOException in TCP reader: $ex")
onDeviceDisconnect(false)
} catch (ex: Throwable) {
Exceptions.report(ex, "Exception in TCP reader")
onDeviceDisconnect(false)
while (true) {
try {
startConnect()
} catch (ex: IOException) {
errormsg("IOException in TCP reader: $ex")
onDeviceDisconnect(false)
} catch (ex: Throwable) {
Exceptions.report(ex, "Exception in TCP reader")
onDeviceDisconnect(false)
}
if (retryCount > MAX_RETRIES_ALLOWED) break
debug("Reconnect attempt $retryCount in ${backoffDelay / 1000}s")
delay(backoffDelay)
retryCount++
backoffDelay = minOf(backoffDelay * 2, MAX_BACKOFF_MILLIS)
}
debug("Exiting TCP reader")
}
@ -85,6 +103,9 @@ class TCPInterface(service: RadioInterfaceService, private val address: String)
BufferedInputStream(socket.getInputStream()).use { inputStream ->
super.connect()
retryCount = 1
backoffDelay = MIN_BACKOFF_MILLIS
var timeoutCount = 0
while (timeoutCount < 180) try { // close after 90s of inactivity
val c = inputStream.read()