altosdroid: Send LOCATION and CRC_ERROR messages to UI.
authorKeith Packard <keithp@keithp.com>
Fri, 12 Apr 2013 05:34:36 +0000 (22:34 -0700)
committerKeith Packard <keithp@keithp.com>
Fri, 12 Apr 2013 05:34:36 +0000 (22:34 -0700)
This collects all position changes and crc error increments and sends
them along to the UI for presentation.

Signed-off-by: Keith Packard <keithp@keithp.com>
altosdroid/src/org/altusmetrum/AltosDroid/TelemetryReader.java
altosdroid/src/org/altusmetrum/AltosDroid/TelemetryService.java

index 9460bdbc2817e904646a1430caf8e7944321cf78..fb07442ee47e0c6d38c492aae50c0c4922440b7f 100644 (file)
@@ -36,6 +36,7 @@ public class TelemetryReader extends Thread {
 \r
        Handler     handler;\r
 \r
+       TelemetryService service;\r
        AltosLink   link;\r
        AltosRecord previous;\r
 \r
@@ -68,12 +69,12 @@ public class TelemetryReader extends Thread {
                                        if (record == null)\r
                                                break;\r
                                        state = new AltosState(record, state);\r
-\r
-                                       handler.obtainMessage(TelemetryService.MSG_TELEMETRY, state).sendToTarget();\r
+                                       service.sendTelemetry(state);\r
                                } catch (ParseException pp) {\r
                                        Log.e(TAG, String.format("Parse error: %d \"%s\"", pp.getErrorOffset(), pp.getMessage()));\r
                                } catch (AltosCRCException ce) {\r
                                        ++crc_errors;\r
+                                       service.sendCrcErrors(crc_errors);\r
                                }\r
                        }\r
                } catch (InterruptedException ee) {\r
@@ -83,7 +84,8 @@ public class TelemetryReader extends Thread {
                }\r
        }\r
 \r
-       public TelemetryReader (AltosLink in_link, Handler in_handler) {\r
+       public TelemetryReader (TelemetryService in_service, AltosLink in_link, Handler in_handler) {\r
+               service = in_service;\r
                link    = in_link;\r
                handler = in_handler;\r
 \r
index e1a5ada8ed2dd02e820f215268bcc4c8480f87b5..98b7d32ff68eff665732cf6685dac49f3244c129 100644 (file)
@@ -45,9 +45,11 @@ import android.location.LocationListener;
 import org.altusmetrum.altoslib_1.*;
 
 class AltosLocationListener implements LocationListener {
+       TelemetryService service;
        boolean fine;
 
        public void onLocationChanged(Location location) {
+               service.sendLocation(location);
        }
 
        public void onStatusChanged(String provider, int status, Bundle extras) {
@@ -59,8 +61,9 @@ class AltosLocationListener implements LocationListener {
        public void onProviderDisabled(String provider) {
        }
 
-       public AltosLocationListener(boolean fine) {
+       public AltosLocationListener(TelemetryService service, boolean fine) {
                this.fine = fine;
+               this.service = service;
        }
 }
 
@@ -77,6 +80,8 @@ public class TelemetryService extends Service {
        static final int MSG_DISCONNECTED      = 6;
        static final int MSG_TELEMETRY         = 7;
        static final int MSG_SETFREQUENCY      = 8;
+       static final int MSG_LOCATION          = 9;
+       static final int MSG_CRC_ERROR         = 10;
 
        public static final int STATE_NONE       = 0;
        public static final int STATE_READY      = 1;
@@ -110,6 +115,12 @@ public class TelemetryService extends Service {
        private AltosLocationListener gpsListener;
        private AltosLocationListener netListener;
        
+       // Last data seen; send to UI when it starts
+
+       private AltosState last_state;
+       private Location last_location;
+       private int last_crc_errors;
+
        // Handler of incoming messages from clients.
        static class IncomingHandler extends Handler {
                private final WeakReference<TelemetryService> service;
@@ -129,6 +140,12 @@ public class TelemetryService extends Service {
                                        s.mClients.remove(msg.replyTo);
                                }
                                if (D) Log.d(TAG, "Client bound to service");
+                               if (s.last_state != null)
+                                       s.sendTelemetry(s.last_state);
+                               if (s.last_location != null)
+                                       s.sendLocation(s.last_location);
+                               if (s.last_crc_errors != 0)
+                                       s.sendCrcErrors(s.last_crc_errors);
                                break;
                        case MSG_UNREGISTER_CLIENT:
                                s.mClients.remove(msg.replyTo);
@@ -172,6 +189,21 @@ public class TelemetryService extends Service {
                }
        }
 
+       public void sendTelemetry(AltosState state) {
+               last_state = state;
+               mHandler.obtainMessage(MSG_TELEMETRY, state).sendToTarget();
+       }
+
+       public void sendLocation(Location location) {
+               last_location = location;
+               mHandler.obtainMessage(MSG_LOCATION, location).sendToTarget();
+       }
+
+       public void sendCrcErrors(int crc_errors) {
+               last_crc_errors = crc_errors;
+               mHandler.obtainMessage(MSG_CRC_ERROR, new Integer(crc_errors)).sendToTarget();
+       }
+
        private void sendMessageToClients(Message m) {
                for (int i=mClients.size()-1; i>=0; i--) {
                        try {
@@ -249,7 +281,7 @@ public class TelemetryService extends Service {
 
                setState(STATE_CONNECTED);
 
-               mTelemetryReader = new TelemetryReader(mAltosBluetooth, mHandler);
+               mTelemetryReader = new TelemetryReader(this, mAltosBluetooth, mHandler);
                mTelemetryReader.start();
                
                mTelemetryLogger = new TelemetryLogger(this, mAltosBluetooth);
@@ -279,8 +311,8 @@ public class TelemetryService extends Service {
                timer.scheduleAtFixedRate(new TimerTask(){ public void run() {onTimerTick();}}, 10000L, 10000L);
 
                // Listen for GPS and Network position updates
-               gpsListener = new AltosLocationListener(true);
-               netListener = new AltosLocationListener(false);
+               gpsListener = new AltosLocationListener(this, true);
+               netListener = new AltosLocationListener(this, false);
 
                LocationManager locationManager = (LocationManager) this.getSystemService(Context.LOCATION_SERVICE);