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

WIP - cleaned up BLE vs serial interface approximately works

Browse source
This commit is contained in:
geeksville 2020-06-07 17:11:30 -07:00
parent e99e8695fe
commit 30137efc68
10 changed files with 411 additions and 365 deletions
Download patch file Download diff file Expand all files Collapse all files

123
app/src/main/java/com/geeksville/mesh/service/SerialInterfaceService.kt
View file

@ -1,123 +0,0 @@
package com.geeksville.mesh.service
import android.content.Context
import android.hardware.usb.UsbManager
import com.hoho.android.usbserial.driver.UsbSerialDriver
import com.hoho.android.usbserial.driver.UsbSerialPort
import com.hoho.android.usbserial.driver.UsbSerialProber
class SerialInterfaceService : InterfaceService() {
companion object {
private val START1 = 0x94.toByte()
private val START2 = 0xc3.toByte()
private val MAX_TO_FROM_RADIO_SIZE = 512
}
private var uart: UsbSerialPort? = null
private val manager: UsbManager by lazy {
getSystemService(Context.USB_SERVICE) as UsbManager
}
override fun handleSendToRadio(p: ByteArray) {
uart?.apply {
val header = ByteArray(4)
header[0] = START1
header[1] = START2
header[2] = (p.size shr 8).toByte()
header[3] = (p.size and 0xff).toByte()
write(header, 0)
write(p, 0)
}
}
/** Print device serial debug output somewhere */
private fun debugOut(c: Byte) {
}
private fun readerLoop() {
try {
val scratch = ByteArray(1)
/** The index of the next byte we are hoping to receive */
var ptr = 0
/** The two halves of our length */
var msb = 0
var lsb = 0
while (true) { // FIXME wait for someone to ask us to exit, and catch continuation exception
uart?.apply {
read(scratch, 0)
val c = scratch[0]
// Assume we will be advancing our pointer
var nextPtr = ptr + 1
when (ptr) {
0 -> // looking for START1
if (c != START1) {
debugOut(c)
nextPtr = 0 // Restart from scratch
}
1 -> // Looking for START2
if (c != START2)
nextPtr = 0 // Restart from scratch
2 -> // Looking for MSB of our 16 bit length
msb = c.toInt() and 0xff
3 -> // Looking for LSB of our 16 bit length
lsb = c.toInt() and 0xff
else -> { // We've read our header, do one big read for the packet itself
val packetLen = (msb shl 8) or lsb
// If packet len is too long, the bytes must have been corrupted, start looking for START1 again
if (packetLen <= MAX_TO_FROM_RADIO_SIZE) {
val buf = ByteArray(packetLen)
read(buf, 0)
handleFromRadio(buf)
}
nextPtr = 0 // Start parsing the next packet
}
}
ptr = nextPtr
}
}
} catch (ex: Exception) {
errormsg("Terminating reader thread due to ${ex.message}", ex)
}
}
override fun onCreate() {
super.onCreate()
val drivers = UsbSerialProber.getDefaultProber().findAllDrivers(manager)
// Open a connection to the first available driver.
// Open a connection to the first available driver.
val driver: UsbSerialDriver = drivers[0]
val connection = manager.openDevice(driver.device)
if (connection == null) {
// FIXME add UsbManager.requestPermission(driver.getDevice(), ..) handling to activity
TODO()
} else {
val port = driver.ports[0] // Most devices have just one port (port 0)
port.open(connection)
port.setParameters(921600, 8, UsbSerialPort.STOPBITS_1, UsbSerialPort.PARITY_NONE)
uart = port
// FIXME, start reading thread
}
}
override fun onDestroy() {
uart?.close()
uart = null
super.onDestroy()
}
}