X-Git-Url: https://git.gag.com/?p=fw%2Faltos;a=blobdiff_plain;f=altoslib%2FAltosTelemetryReader.java;h=b3b97faea349f7212dd724d647fba46ff9cca142;hp=7539452d4ad9cf3cb609a48b58292b197e128911;hb=c0ce45100dd205f59cd84465138c74d9b31df0bb;hpb=8c212cd5bfa03f71a31d84bd0051314e77d88461

diff --git a/altoslib/AltosTelemetryReader.java b/altoslib/AltosTelemetryReader.java
index 7539452d..b3b97fae 100644
--- a/altoslib/AltosTelemetryReader.java
+++ b/altoslib/AltosTelemetryReader.java
@@ -28,20 +28,16 @@ public class AltosTelemetryReader extends AltosFlightReader {
 	int		telemetry;
 	int		telemetry_rate;
 	AltosState	state = null;
-	AltosFlightReader	stacked;
 
 	LinkedBlockingQueue<AltosLine> telem;
 
 	public AltosState read() throws InterruptedException, ParseException, AltosCRCException, IOException {
-		if (stacked != null) {
-			state = stacked.read();
-			if (state != null)
-				return state;
-			stacked = null;
-		}
-		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();
@@ -61,11 +57,6 @@ public class AltosTelemetryReader extends AltosFlightReader {
 
 	public void close(boolean interrupted) {
 
-		if (stacked != null) {
-			stacked.close(interrupted);
-			stacked = null;
-		}
-
 		link.remove_monitor(telem);
 		log.close();
 		try {
@@ -161,10 +152,9 @@ public class AltosTelemetryReader extends AltosFlightReader {
 		return link.monitor_battery();
 	}
 
-	public AltosTelemetryReader (AltosLink in_link, AltosFlightReader in_stacked)
+	public AltosTelemetryReader (AltosLink in_link)
 		throws IOException, InterruptedException, TimeoutException {
 		link = in_link;
-		stacked = in_stacked;
 		boolean success = false;
 		try {
 			log = new AltosLog(link);
@@ -183,22 +173,4 @@ public class AltosTelemetryReader extends AltosFlightReader {
 				close(true);
 		}
 	}
-
-	private static AltosFlightReader existing_data(AltosLink link) {
-		if (link == null)
-			return null;
-
-		File	file = AltosPreferences.logfile(link.serial);
-		if (file != null) {
-			AltosStateIterable	iterable = AltosStateIterable.iterable(file);
-			if (iterable != null)
-				return new AltosReplayReader(iterable.iterator(), file, false);
-		}
-		return null;
-	}
-
-	public AltosTelemetryReader(AltosLink link)
-		throws IOException, InterruptedException, TimeoutException {
-		this(link, existing_data(link));
-	}
 }