X-Git-Url: https://git.gag.com/?p=fw%2Faltos;a=blobdiff_plain;f=altosui%2FAltosEepromDownload.java;h=e7e52466b71b24cd577036e18b51dde4bcf8a3e7;hp=9a748710a3fa5063c91f4316544ee08c786c95cf;hb=f6f54d70b768dca1715ddddea64a4df00d82b09e;hpb=bd2480fd757b67557d9c7de42e402034002c3e37

diff --git a/altosui/AltosEepromDownload.java b/altosui/AltosEepromDownload.java
index 9a748710..e7e52466 100644
--- a/altosui/AltosEepromDownload.java
+++ b/altosui/AltosEepromDownload.java
@@ -33,21 +33,26 @@ import libaltosJNI.*;
 public class AltosEepromDownload implements Runnable {
 
 	JFrame			frame;
-	AltosDevice		device;
 	AltosSerial		serial_line;
 	boolean			remote;
 	Thread			eeprom_thread;
 	AltosEepromMonitor	monitor;
-	int			serial = 0;
-	int			flight = 0;
-	int			year = 0, month = 0, day = 0;
-	boolean			want_file = false;
-	FileWriter		eeprom_file = null;
-	LinkedList<String>	eeprom_pending = new LinkedList<String>();
-	AltosConfigData		config_data;
+
+	int			flight;
+	int			serial;
+	int			year, month, day;
+	boolean			want_file;
+	FileWriter		eeprom_file;
+	LinkedList<String>	eeprom_pending;
+
+	AltosEepromList		flights;
+	ActionListener		listener;
+	boolean			success;
+	ParseException		parse_exception;
+	String			extension;
 
 	private void FlushPending() throws IOException {
-		for (String s : config_data) {
+		for (String s : flights.config_data) {
 			eeprom_file.write(s);
 			eeprom_file.write('\n');
 		}
@@ -61,10 +66,13 @@ public class AltosEepromDownload implements Runnable {
 			return;
 		if (force || (flight != 0 && want_file)) {
 			AltosFile		eeprom_name;
+
+			if (extension == null)
+				extension = "data";
 			if (year != 0 && month != 0 && day != 0)
-				eeprom_name = new AltosFile(year, month, day, serial, flight, "eeprom");
+				eeprom_name = new AltosFile(year, month, day, serial, flight, extension);
 			else
-				eeprom_name = new AltosFile(serial, flight, "eeprom");
+				eeprom_name = new AltosFile(serial, flight, extension);
 
 			eeprom_file = new FileWriter(eeprom_name);
 			if (eeprom_file != null) {
@@ -75,59 +83,235 @@ public class AltosEepromDownload implements Runnable {
 		}
 	}
 
-	void CaptureLog(int start_block, int end_block) throws IOException, InterruptedException, TimeoutException {
-		int			block, state_block = 0;
-		int			state = 0;
-		boolean			done = false;
-		int			record;
-
-		config_data = new AltosConfigData(serial_line);
-		serial = config_data.serial;
-		if (serial == 0)
-			throw new IOException("no serial number found");
+	void Log(AltosEepromRecord r) throws IOException {
+		if (r.cmd != Altos.AO_LOG_INVALID) {
+			String log_line = String.format("%c %4x %4x %4x\n",
+							r.cmd, r.tick, r.a, r.b);
+			if (eeprom_file != null)
+				eeprom_file.write(log_line);
+			else
+				eeprom_pending.add(log_line);
+		}
+	}
 
+	void set_serial(int in_serial) {
+		serial = in_serial;
 		monitor.set_serial(serial);
-		/* Now scan the eeprom, reading blocks of data and converting to .eeprom file form */
+	}
 
-		state = 0; state_block = start_block;
-		for (block = start_block; !done && block < end_block; block++) {
-			monitor.set_value(Altos.state_to_string[state], state, block - state_block);
+	void set_flight(int in_flight) {
+		flight = in_flight;
+		monitor.set_flight(flight);
+	}
+		
+	boolean			done;
+	int			state;
+
+	void CaptureFull(AltosEepromChunk eechunk) throws IOException {
+		boolean	any_valid = false;
 
-			AltosEepromBlock	eeblock = new AltosEepromBlock(serial_line, block);
-			if (eeblock.has_flight) {
-				flight = eeblock.flight;
-				monitor.set_flight(flight);
+		extension = "eeprom";
+		set_serial(flights.config_data.serial);
+		for (int i = 0; i < eechunk.chunk_size && !done; i += AltosEepromRecord.record_length) {
+			try {
+				AltosEepromRecord r = new AltosEepromRecord(eechunk, i);
+				if (r.cmd == Altos.AO_LOG_FLIGHT)
+					set_flight(r.b);
+
+				/* Monitor state transitions to update display */
+				if (r.cmd == Altos.AO_LOG_STATE && r.a <= Altos.ao_flight_landed) {
+					state = r.a;
+					if (state > Altos.ao_flight_pad)
+						want_file = true;
+				}
+
+				if (r.cmd == Altos.AO_LOG_GPS_DATE) {
+					year = 2000 + (r.a & 0xff);
+					month = (r.a >> 8) & 0xff;
+					day = (r.b & 0xff);
+					want_file = true;
+				}
+				if (r.cmd == Altos.AO_LOG_STATE && r.a == Altos.ao_flight_landed)
+					done = true;
+				any_valid = true;
+				Log(r);
+			} catch (ParseException pe) {
+				if (parse_exception == null)
+					parse_exception = pe;
 			}
-			if (eeblock.has_date) {
-				year = eeblock.year;
-				month = eeblock.month;
-				day = eeblock.day;
-				want_file = true;
+		}
+
+		if (!any_valid)
+			done = true;
+
+		CheckFile(false);
+	}
+
+	boolean	start;
+	int	tiny_tick;
+
+	void CaptureTiny (AltosEepromChunk eechunk) throws IOException {
+		boolean any_valid = false;
+
+		extension = "eeprom";
+		set_serial(flights.config_data.serial);
+		for (int i = 0; i < eechunk.data.length && !done; i += 2) {
+			int			v = eechunk.data16(i);
+			AltosEepromRecord	r;
+
+			if (i == 0 && start) {
+				tiny_tick = 0;
+				start = false;
+				set_flight(v);
+				r = new AltosEepromRecord(Altos.AO_LOG_FLIGHT, tiny_tick, 0, v);
+				any_valid = true;
+			} else {
+				int	s = v ^ 0x8000;
+
+				if (Altos.ao_flight_startup <= s && s <= Altos.ao_flight_invalid) {
+					state = s;
+					r = new AltosEepromRecord(Altos.AO_LOG_STATE, tiny_tick, state, 0);
+					if (state == Altos.ao_flight_landed)
+						done = true;
+					state = s;
+					any_valid = true;
+				} else {
+					if (v != 0xffff)
+						any_valid = true;
+
+					r = new AltosEepromRecord(Altos.AO_LOG_PRESSURE, tiny_tick, 0, v);
+
+					/*
+					 * The flight software records ascent data every 100ms, and descent
+					 * data every 1s.
+					 */
+					if (state < Altos.ao_flight_drogue)
+						tiny_tick += 10;
+					else
+						tiny_tick += 100;
+				}
 			}
+			Log(r);
+		}
+		CheckFile(false);
+		if (!any_valid)
+			done = true;
+	}
 
-			if (eeblock.size() == 0 ||
-			    eeblock.has_state && eeblock.state == Altos.ao_flight_landed)
-					done = true;
+	void LogTeleScience(AltosEepromTeleScience r) throws IOException {
+		if (r.type != Altos.AO_LOG_INVALID) {
+			String log_line = String.format("%c %4x %4x %d %5d %5d %5d %5d %5d %5d %5d %5d %5d %5d %5d %5d\n",
+							r.type, r.tick, r.tm_tick, r.tm_state,
+							r.data[0], r.data[1], r.data[2], r.data[3], 
+							r.data[4], r.data[5], r.data[6], r.data[7], 
+							r.data[8], r.data[9], r.data[10], r.data[11]);
+			if (eeprom_file != null)
+				eeprom_file.write(log_line);
+			else
+				eeprom_pending.add(log_line);
+		}
+	}
+	
+	boolean	telescience_start;
 
-			/* Monitor state transitions to update display */
-			if (eeblock.has_state) {
-				if (eeblock.state > Altos.ao_flight_pad)
-					want_file = true;
-				if (eeblock.state > state)
-					state = eeblock.state;
+	void CaptureTeleScience (AltosEepromChunk eechunk) throws IOException {
+		boolean	any_valid = false;
+
+		extension = "science";
+		for (int i = 0; i < eechunk.chunk_size && !done; i += AltosEepromTeleScience.record_length) {
+			try {
+				AltosEepromTeleScience r = new AltosEepromTeleScience(eechunk, i);
+				if (r.type == AltosEepromTeleScience.AO_LOG_TELESCIENCE_START) {
+					if (telescience_start) {
+						done = true;
+						break;
+					}
+					set_serial(r.data[0]);
+					set_flight(r.data[1]);
+					telescience_start = true;
+				} else {
+					if (!telescience_start)
+						break;
+				}
+				state = r.tm_state;
+				want_file =true;
+				any_valid = true;
+				LogTeleScience(r);
+			} catch (ParseException pe) {
+				if (parse_exception == null)
+					parse_exception = pe;
 			}
+		}
+
+		CheckFile(false);
+		if (!any_valid)
+			done = true;
+	}
 
-			CheckFile(true);
+	void CaptureTelemetry(AltosEepromChunk eechunk) throws IOException {
+		
+	}
 
-			for (record = 0; record < eeblock.size(); record++) {
-				AltosEepromRecord r = eeblock.get(record);
+	void CaptureLog(AltosEepromLog log) throws IOException, InterruptedException, TimeoutException {
+		int			block, state_block = 0;
+		int			log_format = flights.config_data.log_format;
 
-				String log_line = String.format("%c %4x %4x %4x\n",
-								r.cmd, r.tick, r.a, r.b);
-				if (eeprom_file != null)
-					eeprom_file.write(log_line);
-				else
-					eeprom_pending.add(log_line);
+		state = 0;
+		done = false;
+		start = true;
+
+		if (flights.config_data.serial == 0)
+			throw new IOException("no serial number found");
+
+		/* Reset per-capture variables */
+		flight = 0;
+		year = 0;
+		month = 0;
+		day = 0;
+		want_file = false;
+		eeprom_file = null;
+		eeprom_pending = new LinkedList<String>();
+
+		/* Set serial number in the monitor dialog window */
+		/* Now scan the eeprom, reading blocks of data and converting to .eeprom file form */
+
+		state = 0; state_block = log.start_block;
+		for (block = log.start_block; !done && block < log.end_block; block++) {
+			monitor.set_value(Altos.state_to_string[state], state, block - state_block);
+
+			AltosEepromChunk	eechunk = new AltosEepromChunk(serial_line, block, block == log.start_block);
+
+			/*
+			 * Guess what kind of data is there if the device
+			 * didn't tell us
+			 */
+
+			if (log_format == Altos.AO_LOG_FORMAT_UNKNOWN) {
+				if (block == log.start_block) {
+					if (eechunk.data(0) == Altos.AO_LOG_FLIGHT)
+						log_format = Altos.AO_LOG_FORMAT_FULL;
+					else
+						log_format = Altos.AO_LOG_FORMAT_TINY;
+				}
+			}
+
+			switch (log_format) {
+			case Altos.AO_LOG_FORMAT_FULL:
+				extension = "eeprom";
+				CaptureFull(eechunk);
+				break;
+			case Altos.AO_LOG_FORMAT_TINY:
+				extension = "eeprom";
+				CaptureTiny(eechunk);
+				break;
+			case Altos.AO_LOG_FORMAT_TELEMETRY:
+				extension = "telem";
+				CaptureTelemetry(eechunk);
+				break;
+			case Altos.AO_LOG_FORMAT_TELESCIENCE:
+				extension = "science";
+				CaptureTeleScience(eechunk);
+				break;
 			}
 		}
 		CheckFile(true);
@@ -137,20 +321,21 @@ public class AltosEepromDownload implements Runnable {
 		}
 	}
 
-	private void show_error_internal(String message, String title) {
+	private void show_message_internal(String message, String title, int message_type) {
 		JOptionPane.showMessageDialog(frame,
 					      message,
 					      title,
-					      JOptionPane.ERROR_MESSAGE);
+					      message_type);
 	}
 
-	private void show_error(String in_message, String in_title) {
+	private void show_message(String in_message, String in_title, int in_message_type) {
 		final String message = in_message;
 		final String title = in_title;
+		final int message_type = in_message_type;
 		Runnable r = new Runnable() {
 				public void run() {
 					try {
-						show_error_internal(message, title);
+						show_message_internal(message, title, message_type);
 					} catch (Exception ex) {
 					}
 				}
@@ -158,75 +343,91 @@ public class AltosEepromDownload implements Runnable {
 		SwingUtilities.invokeLater(r);
 	}
 
-	int	start_block, end_block;
-
 	public void run () {
-		if (remote) {
-			serial_line.set_radio();
-			serial_line.printf("p\nE 0\n");
-			serial_line.flush_input();
-		}
-
 		try {
-			CaptureLog(start_block, end_block);
+			boolean	failed = false;
+			if (remote)
+				serial_line.start_remote();
+
+			for (AltosEepromLog log : flights) {
+				parse_exception = null;
+				if (log.download) {
+					monitor.reset();
+					CaptureLog(log);
+				}
+				if (parse_exception != null) {
+					failed = true;
+					show_message(String.format("Flight %d download error\n%s\nValid log data saved",
+								   log.flight,
+								   parse_exception.getMessage()),
+						     serial_line.device.toShortString(),
+						     JOptionPane.WARNING_MESSAGE);
+				}
+			}
+			success = !failed;
 		} catch (IOException ee) {
-			show_error (device.toShortString(),
-				    ee.getLocalizedMessage());
+			show_message(ee.getLocalizedMessage(),
+				     serial_line.device.toShortString(),
+				     JOptionPane.ERROR_MESSAGE);
 		} catch (InterruptedException ie) {
+			System.out.printf("download interrupted\n");
 		} catch (TimeoutException te) {
-			show_error (String.format("Connection to \"%s\" failed",
-						  device.toShortString()),
-				    "Connection Failed");
+			show_message(String.format("Connection to \"%s\" failed",
+						   serial_line.device.toShortString()),
+				     "Connection Failed",
+				     JOptionPane.ERROR_MESSAGE);
+		} finally {
+			if (remote) {
+				try {
+					serial_line.stop_remote();
+				} catch (InterruptedException ie) {
+				}
+			}
+			serial_line.flush_output();
 		}
-		if (remote)
-			serial_line.printf("~");
 		monitor.done();
-		serial_line.flush_output();
-		serial_line.close();
+		if (listener != null) {
+			Runnable r = new Runnable() {
+					public void run() {
+						try {
+							listener.actionPerformed(new ActionEvent(this,
+												 success ? 1 : 0,
+												 "download"));
+						} catch (Exception ex) {
+						}
+					}
+				};
+			SwingUtilities.invokeLater(r);
+		}
 	}
 
-	public AltosEepromDownload(JFrame given_frame) {
-		frame = given_frame;
-		device = AltosDeviceDialog.show(frame, AltosDevice.product_any);
+	public void start() {
+		eeprom_thread = new Thread(this);
+		eeprom_thread.start();
+	}
 
-		remote = false;
+	public void addActionListener(ActionListener l) {
+		listener = l;
+	}
 
-		if (device != null) {
-			try {
-				serial_line = new AltosSerial(device);
-				if (!device.matchProduct(AltosDevice.product_telemetrum))
-					remote = true;
-
-				monitor = new AltosEepromMonitor(frame, Altos.ao_flight_boost, Altos.ao_flight_landed);
-				monitor.addActionListener(new ActionListener() {
-						public void actionPerformed(ActionEvent e) {
-							if (eeprom_thread != null)
-								eeprom_thread.interrupt();
-						}
-					});
-
-				eeprom_thread = new Thread(this);
-				start_block = 0;
-				end_block = 0xfff;
-				eeprom_thread.start();
-			} catch (FileNotFoundException ee) {
-				JOptionPane.showMessageDialog(frame,
-							      String.format("Cannot open device \"%s\"",
-									    device.toShortString()),
-							      "Cannot open target device",
-							      JOptionPane.ERROR_MESSAGE);
-			} catch (AltosSerialInUseException si) {
-				JOptionPane.showMessageDialog(frame,
-							      String.format("Device \"%s\" already in use",
-									    device.toShortString()),
-							      "Device in use",
-							      JOptionPane.ERROR_MESSAGE);
-			} catch (IOException ee) {
-				JOptionPane.showMessageDialog(frame,
-							      device.toShortString(),
-							      ee.getLocalizedMessage(),
-							      JOptionPane.ERROR_MESSAGE);
-			}
-		}
+	public AltosEepromDownload(JFrame given_frame,
+				   AltosSerial given_serial_line,
+				   boolean given_remote,
+				   AltosEepromList given_flights) {
+
+		frame = given_frame;
+		serial_line = given_serial_line;
+		serial_line.set_frame(frame);
+		remote = given_remote;
+		flights = given_flights;
+		success = false;
+
+		monitor = new AltosEepromMonitor(frame, Altos.ao_flight_boost, Altos.ao_flight_landed);
+		monitor.addActionListener(new ActionListener() {
+				public void actionPerformed(ActionEvent e) {
+					if (eeprom_thread != null)
+						eeprom_thread.interrupt();
+				}
+			});
 	}
 }