X-Git-Url: https://git.gag.com/?a=blobdiff_plain;f=altoslib%2FAltosReplayReader.java;h=15093af18410a1180e4c8c3bf8a66dee5718ba4d;hb=HEAD;hp=ec682bd4757ea949c9dd402f9e5601e333a0568f;hpb=58e7fccc24f933fd64e272207f783ca79002b7ba;p=fw%2Faltos diff --git a/altoslib/AltosReplayReader.java b/altoslib/AltosReplayReader.java index ec682bd4..bcabf750 100644 --- a/altoslib/AltosReplayReader.java +++ b/altoslib/AltosReplayReader.java @@ -16,7 +16,7 @@ * 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA. */ -package org.altusmetrum.altoslib_13; +package org.altusmetrum.altoslib_14; import java.io.*; import java.util.*; @@ -35,13 +35,15 @@ class AltosReplay extends AltosDataListener implements Runnable { boolean done = false; public void set_time(double time) { - if (last_time != AltosLib.MISSING) { - semaphore.release(); - double delay = Math.min(time - last_time,10); - if (delay > 0) { - try { - Thread.sleep((int) (delay * 1000)); - } catch (InterruptedException ie) { + if (time > -2) { + if (last_time != AltosLib.MISSING) { + semaphore.release(); + double delay = Math.min(time - last_time,10); + if (delay > 0) { + try { + Thread.sleep((int) (delay * 1000)); + } catch (InterruptedException ie) { + } } } } @@ -84,6 +86,7 @@ class AltosReplay extends AltosDataListener implements Runnable { public void set_igniter_voltage(double[] voltage) { state.set_igniter_voltage(voltage); } public void set_pyro_fired(int pyro_mask) { state.set_pyro_fired(pyro_mask); } public void set_companion(AltosCompanion companion) { state.set_companion(companion); } + public void set_motor_pressure(double motor_pressure) { state.set_motor_pressure(motor_pressure); } public void run () { /* Run the flight */ @@ -108,31 +111,17 @@ public class AltosReplayReader extends AltosFlightReader { File file; AltosReplay replay; Thread t; - int reads; public AltosCalData cal_data() { return replay.state.cal_data(); } public AltosState read() { - switch (reads) { - case 0: - /* Tell the display that we're in pad mode */ - replay.state.set_state(AltosLib.ao_flight_pad); - break; - case 1: - t = new Thread(replay); - t.start(); - /* fall through */ - default: - /* Wait for something to change */ - try { - replay.semaphore.acquire(); - } catch (InterruptedException ie) { - } - break; + /* Wait for something to change */ + try { + replay.semaphore.acquire(); + } catch (InterruptedException ie) { } - reads++; /* When done, let the display know */ if (replay.done) @@ -149,9 +138,10 @@ public class AltosReplayReader extends AltosFlightReader { public File backing_file() { return file; } public AltosReplayReader(AltosRecordSet record_set, File in_file) { - reads = 0; file = in_file; name = file.getName(); replay = new AltosReplay(record_set); + t = new Thread(replay); + t.start(); } }