Попытка понять поведение передачи данных (LAG) на подключении Bluetooth с использованием платы HC-05 (подключено к Ardui ⇐ Android

[Anonymous]

Что у меня есть < /h2>

У меня есть аппаратный датчик и HC-05, подключенный к Arduino. Arduino собирает данные датчиков и передает их в реальном времени через Bluetooth HC 05 на устройство для анализа. < /p>

Каждый кадр данных датчика составляет 44 байта. < /p>

Скорость передачи данных в среднем составляет 2200 байтов в секунду. < /p>

Существует пользовательское приложение для Android, которое обрабатывает данные датчика. Ардуино. После этого каждые несколько сотен кадров наблюдается большая задержка 450-950 мс до получения дополнительных данных. < /P>

Примечание: < /em> Эта команда не влияет на функцию, упомянутую выше. Есть и другие команды, отправляемые время от времени от Android -телефона в Arduino. < /P>



Другие наблюдения < /p>


[*] Из -за Arduino, и, по -видимому, не соблюдает нормальное значение. Не отправлять никаких команд, задержка не наблюдалась до тех пор, пока анализ выполняется (около 12 минут).
никакой кадры не пропускается/не было пропущено/отброшено во время любого из сценариев (с задержкой или без него). то есть все данные передаются и принимаются. < /p> < /li>
< /ol>

Может ли кто -нибудь помочь мне понять, почему генерируется эта огромная задержка? < /p>

Если какая -либо информация требуется, пожалуйста, прокомментируйте, и я буду рад предоставить. Оба потока используются только для одной цели (поток писателя вряд ли задействует, как можно было бы ожидать). < /P>

Соответствующий код: < /h2>

После подключения поток, который считывает из inputstream < /p>

inner class ReaderThread : Thread("CBT_reader") {
private var bytesRead: Int = 0
private var buffer = ByteArray(2)
private lateinit var trimmedBuffer: ByteArray

override fun run() {
try {

while (true) {
bytesRead = mmInStream.read(buffer)

trimmedBuffer = ByteArray(bytesRead)
System.arraycopy(buffer, 0, trimmedBuffer, 0, bytesRead)
observer.notify(trimmedBuffer)
}

} catch (e: IOException) {
logger.logException(e)
logger.logw(e.message ?: "Read error")
tryDisconnect()

} catch (e2: InterruptedException) {
logger.logd("Reader has been interrupted")

}

}

fun abort() {
interrupt()
mmOutStream.close()
mmInStream.close()
btSocket.close()
}
}
< /code>

Thread, < /p>

inner class WriterThread : Thread() {
private val queue = LinkedBlockingQueue()

fun putInQueue(b: ByteArray) {
queue.put(b)
}

override fun run() {
while (true) {
try {
mmOutStream.write(queue.take())
logger.logd("Data frame written")

} catch (e: IOException) {
//write failed
logger.logException(e)
logger.logw(e.message ?: "Write error")
tryDisconnect()
break

} catch (e2: InterruptedException) {
logger.logd("Writer has been interrupted")
break
}
}
}

fun abort() {
interrupt()

}
}


Подробнее здесь: https://stackoverflow.com/questions/534 ... ection-usi