MarcoBuster/Gadgetbridge
1
0
Fork 0
mirror of https://codeberg.org/Freeyourgadget/Gadgetbridge synced 2024-11-28 21:06:50 +01:00
Code Releases Wiki Activity

Pebble 2: when using client only mode, no not wait for PPoGATT ACKs after each package

Browse Source 
This speeds up things up a lot. We should still somehow limit it, but not by waiting
after one PPoGATT ACK after each complete PP package.

This leaves the old mode untouched, so we have something to compare
This commit is contained in:
Andreas Shimokawa 2018-05-12 17:18:19 +02:00
parent eb08e66674
commit 511fef7f62
1 changed files with 13 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
app/src/main/java/nodomain/freeyourgadget/gadgetbridge/service/devices/pebble/ble/PebbleLESupport.java
View File

@ -156,10 +156,12 @@ public class PebbleLESupport {
int serial = header >> 3; int serial = header >> 3;
if (command == 0x01) { if (command == 0x01) {
LOG.info("got ACK for serial = " + serial); LOG.info("got ACK for serial = " + serial);
if (mPPAck != null) { if (!clientOnly) {
mPPAck.countDown(); if (mPPAck != null) {
} else { mPPAck.countDown();
LOG.warn("mPPAck countdownlatch is not present but it probably should"); } else {
LOG.warn("mPPAck countdownlatch is not present but it probably should");
}
} }
} }
if (command == 0x02) { // some request? if (command == 0x02) { // some request?
@ -224,7 +226,9 @@ public class PebbleLESupport {
int payloadToSend = bytesRead + 4; int payloadToSend = bytesRead + 4;
int srcPos = 0; int srcPos = 0;
mPPAck = new CountDownLatch(1); if (!clientOnly) {
mPPAck = new CountDownLatch(1);
}
while (payloadToSend > 0) { while (payloadToSend > 0) {
int chunkSize = (payloadToSend < (mMTU - 4)) ? payloadToSend : mMTU - 4; int chunkSize = (payloadToSend < (mMTU - 4)) ? payloadToSend : mMTU - 4;
byte[] outBuf = new byte[chunkSize + 1]; byte[] outBuf = new byte[chunkSize + 1];
@ -234,10 +238,10 @@ public class PebbleLESupport {
srcPos += chunkSize; srcPos += chunkSize;
payloadToSend -= chunkSize; payloadToSend -= chunkSize;
} }
if (!clientOnly) {
mPPAck.await(); mPPAck.await();
mPPAck = null; mPPAck = null;
}
} catch (IOException | InterruptedException e) { } catch (IOException | InterruptedException e) {
LOG.info(e.getMessage()); LOG.info(e.getMessage());
Thread.currentThread().interrupt(); Thread.currentThread().interrupt();