X-Git-Url: https://git.gag.com/?a=blobdiff_plain;f=altosdroid%2Fsrc%2Forg%2Faltusmetrum%2FAltosDroid%2FTelemetryReader.java;h=fb07442ee47e0c6d38c492aae50c0c4922440b7f;hb=9a8cc23de5776ea3fa2bdc96cbe63422eb555d63;hp=66e9c6bdd5c25c9b5cfa84999587830e0f96c6ff;hpb=4420d4a9fc011ed970af506ef771dfb81580b666;p=fw%2Faltos diff --git a/altosdroid/src/org/altusmetrum/AltosDroid/TelemetryReader.java b/altosdroid/src/org/altusmetrum/AltosDroid/TelemetryReader.java index 66e9c6bd..fb07442e 100644 --- a/altosdroid/src/org/altusmetrum/AltosDroid/TelemetryReader.java +++ b/altosdroid/src/org/altusmetrum/AltosDroid/TelemetryReader.java @@ -25,7 +25,7 @@ import java.util.concurrent.*; import android.util.Log; import android.os.Handler; -import org.altusmetrum.AltosLib.*; +import org.altusmetrum.altoslib_1.*; public class TelemetryReader extends Thread { @@ -36,6 +36,7 @@ public class TelemetryReader extends Thread { Handler handler; + TelemetryService service; AltosLink link; AltosRecord previous; @@ -68,12 +69,12 @@ public class TelemetryReader extends Thread { if (record == null) break; state = new AltosState(record, state); - - handler.obtainMessage(TelemetryService.MSG_TELEMETRY, state).sendToTarget(); + service.sendTelemetry(state); } catch (ParseException pp) { Log.e(TAG, String.format("Parse error: %d \"%s\"", pp.getErrorOffset(), pp.getMessage())); } catch (AltosCRCException ce) { ++crc_errors; + service.sendCrcErrors(crc_errors); } } } catch (InterruptedException ee) { @@ -83,7 +84,8 @@ public class TelemetryReader extends Thread { } } - public TelemetryReader (AltosLink in_link, Handler in_handler) { + public TelemetryReader (TelemetryService in_service, AltosLink in_link, Handler in_handler) { + service = in_service; link = in_link; handler = in_handler;