diff options
author | Keith Packard <keithp@keithp.com> | 2015-02-07 17:08:03 -0800 |
---|---|---|
committer | Keith Packard <keithp@keithp.com> | 2015-02-07 17:08:03 -0800 |
commit | c0ce45100dd205f59cd84465138c74d9b31df0bb (patch) | |
tree | f743025ea75fb3507da19d7126d5bd0353a65407 /altoslib/AltosTelemetryReader.java | |
parent | 8a2be4d36a3b116d82529805430c5fb665688267 (diff) |
altoslib: Drop telemetry packets processed while monitoring is disabled
A lag between the thread queuing telemetry packets and one pulling
them out can result in stale telemetry data being returned to the
reader. Fix this by dropping telemetry read while monitoring is disabled.
Signed-off-by: Keith Packard <keithp@keithp.com>
Diffstat (limited to 'altoslib/AltosTelemetryReader.java')
-rw-r--r-- | altoslib/AltosTelemetryReader.java | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/altoslib/AltosTelemetryReader.java b/altoslib/AltosTelemetryReader.java index fa136145..b3b97fae 100644 --- a/altoslib/AltosTelemetryReader.java +++ b/altoslib/AltosTelemetryReader.java @@ -32,9 +32,12 @@ public class AltosTelemetryReader extends AltosFlightReader { LinkedBlockingQueue<AltosLine> telem; public AltosState read() throws InterruptedException, ParseException, AltosCRCException, IOException { - AltosLine l = telem.take(); - if (l.line == null) - throw new IOException("IO error"); + AltosLine l; + do { + l = telem.take(); + if (l.line == null) + throw new IOException("IO error"); + } while (!link.get_monitor()); AltosTelemetry telem = AltosTelemetry.parse(l.line); if (state == null) state = new AltosState(); |