Skip to content

Commit

Permalink
revert usb receiver try catch and convert anonymous function to lambda
Browse files Browse the repository at this point in the history
  • Loading branch information
dhruv2295 committed Dec 14, 2020
1 parent 9a5af01 commit d0c1e9f
Show file tree
Hide file tree
Showing 2 changed files with 17 additions and 21 deletions.
11 changes: 4 additions & 7 deletions android/app/src/main/java/org/openbot/NetworkActivity.java
Expand Up @@ -257,13 +257,10 @@ protected void processImage() {
updateVehicleState();

runOnUiThread(
new Runnable() {
@Override
public void run() {
// showFrameInfo(previewWidth + "x" + previewHeight);
// showCropInfo(croppedBitmap.getWidth() + "x" + croppedBitmap.getHeight());
showInference(lastProcessingTimeMs + "ms");
}
() -> {
// showFrameInfo(previewWidth + "x" + previewHeight);
// showCropInfo(croppedBitmap.getWidth() + "x" + croppedBitmap.getHeight());
showInference(lastProcessingTimeMs + "ms");
});
});
}
Expand Down
27 changes: 13 additions & 14 deletions android/app/src/main/java/org/openbot/env/UsbConnection.java
Expand Up @@ -17,6 +17,7 @@
import androidx.localbroadcastmanager.content.LocalBroadcastManager;
import com.felhr.usbserial.UsbSerialDevice;
import com.felhr.usbserial.UsbSerialInterface;
import java.io.UnsupportedEncodingException;
import java.util.Map;
import org.openbot.SensorService;

Expand Down Expand Up @@ -54,20 +55,18 @@ public UsbConnection(Context context, int baudRate) {

private final UsbSerialInterface.UsbReadCallback callback =
data -> {
String dataUtf8 = new String(data, UTF_8);
buffer += dataUtf8;
int index;
while ((index = buffer.indexOf('\n')) != -1) {
final String dataStr = buffer.substring(0, index).trim();
buffer = buffer.length() == index ? "" : buffer.substring(index + 1);

AsyncTask.execute(
new Runnable() {
@Override
public void run() {
onSerialDataReceived(dataStr);
}
});
try {
String dataUtf8 = new String(data, "UTF-8");
buffer += dataUtf8;
int index;
while ((index = buffer.indexOf('\n')) != -1) {
final String dataStr = buffer.substring(0, index).trim();
buffer = buffer.length() == index ? "" : buffer.substring(index + 1);

AsyncTask.execute(() -> onSerialDataReceived(dataStr));
}
} catch (UnsupportedEncodingException e) {
LOGGER.e("Error receiving USB data");
}
};

Expand Down

0 comments on commit d0c1e9f

Please sign in to comment.