altosui: Use timeouts to recover from broken packet links.

This puts timeouts every place the system reads from the packet link
and aborts the in-progress operation if it takes more than a second to
get a response.

Also mixed in here are persistent igniter status displays for the
ejection testing UI.

Signed-off-by: Keith Packard <keithp@keithp.com>

1 files changed, 34 insertions, 24 deletions

diff --git a/ao-tools/altosui/AltosIgnite.java b/ao-tools/altosui/AltosIgnite.java
index 5c27e8fa..8e92ec1b 100644
--- a/ao-tools/altosui/AltosIgnite.java
+++ b/ao-tools/altosui/AltosIgnite.java
@@ -18,6 +18,7 @@
 package altosui;
 
 import java.io.*;
+import java.util.concurrent.*;
 
 public class AltosIgnite {
 	AltosDevice	device;
@@ -91,35 +92,40 @@ public class AltosIgnite {
 		return Unknown;
 	}
 
-	public int status(int igniter) {
+	public int status(int igniter) throws InterruptedException, TimeoutException {
 		int status = Unknown;
 		if (serial == null)
 			return status;
 		string_ref status_name = new string_ref();
-		try {
-			start_serial();
-			serial.printf("t\n");
-			for (;;) {
-				String line = serial.get_reply();
-				if (get_string(line, "Igniter: drogue Status: ", status_name))
-					if (igniter == Apogee)
-						status = status(status_name.get());
-				if (get_string(line, "Igniter:   main Status: ", status_name)) {
-					if (igniter == Main)
-						status = status(status_name.get());
-					break;
-				}
-			}
-		} catch (InterruptedException ie) {
-		} finally {
-			try {
-				stop_serial();
-			} catch (InterruptedException ie) {
+		start_serial();
+		serial.printf("t\n");
+		for (;;) {
+			String line = serial.get_reply(1000);
+			if (line == null)
+				throw new TimeoutException();
+			if (get_string(line, "Igniter: drogue Status: ", status_name))
+				if (igniter == Apogee)
+					status = status(status_name.get());
+			if (get_string(line, "Igniter:   main Status: ", status_name)) {
+				if (igniter == Main)
+					status = status(status_name.get());
+				break;
 			}
 		}
+		stop_serial();
 		return status;
 	}
 
+	public String status_string(int status) {
+		switch (status) {
+		case Unknown: return "Unknown";
+		case Ready: return "Ready";
+		case Active: return "Active";
+		case Open: return "Open";
+		default: return "Unknown";
+		}
+	}
+
 	public void fire(int igniter) {
 		if (serial == null)
 			return;
@@ -142,14 +148,18 @@ public class AltosIgnite {
 		}
 	}
 
+	public void close() {
+		serial.close();
+		serial = null;
+	}
+
 	public AltosIgnite(AltosDevice in_device) throws FileNotFoundException, AltosSerialInUseException {
 
 		device = in_device;
-		serial = null;
-//		serial = new AltosSerial(device);
+		serial = new AltosSerial(device);
 		remote = false;
 
-//		if (!device.matchProduct(AltosDevice.product_telemetrum))
-//			remote = true;
+		if (!device.matchProduct(AltosDevice.product_telemetrum))
+			remote = true;
 	}
 }
\ No newline at end of file