X-Git-Url: https://git.gag.com/?a=blobdiff_plain;f=ao-tools%2Faltosui%2FAltosDisplayThread.java;h=957ac0d69581f00693b59104739a1d23c335943d;hb=eb77e806ded99532dc7eaa39c1893f075b028af6;hp=9cc3d5ce9eb273ae49bab05d2fee22b2642d4d62;hpb=c89a34d1eb25155405b0036baeadc7bbfeade1c2;p=fw%2Faltos

diff --git a/ao-tools/altosui/AltosDisplayThread.java b/ao-tools/altosui/AltosDisplayThread.java
index 9cc3d5ce..957ac0d6 100644
--- a/ao-tools/altosui/AltosDisplayThread.java
+++ b/ao-tools/altosui/AltosDisplayThread.java
@@ -30,13 +30,13 @@ import java.util.concurrent.LinkedBlockingQueue;
 
 public class AltosDisplayThread extends Thread {
 
-	Frame		parent;
-	IdleThread	idle_thread;
-	AltosVoice	voice;
-	String		name;
-	int		crc_errors;
-	AltosStatusTable flightStatus;
-	AltosInfoTable flightInfo;
+	Frame			parent;
+	IdleThread		idle_thread;
+	AltosVoice		voice;
+	String			name;
+	AltosFlightReader	reader;
+	int			crc_errors;
+	AltosFlightDisplay	display;
 
 	class IdleThread extends Thread {
 
@@ -150,14 +150,6 @@ public class AltosDisplayThread extends Thread {
 		}
 	}
 
-	void init() { }
-
-	AltosRecord read() throws InterruptedException, ParseException, AltosCRCException, IOException { return null; }
-
-	void close(boolean interrupted) { }
-
-	void update(AltosState state) throws InterruptedException { }
-
 	boolean tell(AltosState state, AltosState old_state) {
 		boolean	ret = false;
 		if (old_state == null || old_state.state != state.state) {
@@ -189,10 +181,8 @@ public class AltosDisplayThread extends Thread {
 	}
 
 	void show(AltosState state, int crc_errors) {
-		if (state != null) {
-			flightStatus.set(state);
-			flightInfo.show(state, crc_errors);
-		}
+		if (state != null)
+			display.show(state, crc_errors);
 	}
 
 	public void run() {
@@ -204,16 +194,16 @@ public class AltosDisplayThread extends Thread {
 
 		idle_thread = new IdleThread();
 
-		flightInfo.clear();
+		display.reset();
 		try {
 			for (;;) {
 				try {
-					AltosRecord record = read();
+					AltosRecord record = reader.read();
 					if (record == null)
 						break;
 					old_state = state;
 					state = new AltosState(record, state);
-					update(state);
+					reader.update(state);
 					show(state, crc_errors);
 					told = tell(state, old_state);
 					idle_thread.notice(state, told);
@@ -232,7 +222,9 @@ public class AltosDisplayThread extends Thread {
 						      "Telemetry Read Error",
 						      JOptionPane.ERROR_MESSAGE);
 		} finally {
-			close(interrupted);
+			if (!interrupted)
+				idle_thread.report(true);
+			reader.close(interrupted);
 			idle_thread.interrupt();
 			try {
 				idle_thread.join();
@@ -240,16 +232,10 @@ public class AltosDisplayThread extends Thread {
 		}
 	}
 
-	public AltosDisplayThread(Frame in_parent, AltosVoice in_voice, AltosStatusTable in_status, AltosInfoTable in_info) {
+	public AltosDisplayThread(Frame in_parent, AltosVoice in_voice, AltosFlightDisplay in_display, AltosFlightReader in_reader) {
 		parent = in_parent;
 		voice = in_voice;
-		flightStatus = in_status;
-		flightInfo = in_info;
-	}
-
-	public void report() {
-		if (idle_thread != null)
-			idle_thread.report(true);
+		display = in_display;
+		reader = in_reader;
 	}
-
 }