altosui: Use timeouts to recover from broken packet links.
authorKeith Packard <keithp@keithp.com>
Sat, 20 Nov 2010 02:25:48 +0000 (18:25 -0800)
committerKeith Packard <keithp@keithp.com>
Sat, 20 Nov 2010 02:25:48 +0000 (18:25 -0800)
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>
ao-tools/altosui/AltosConfig.java
ao-tools/altosui/AltosEepromDownload.java
ao-tools/altosui/AltosFlashUI.java
ao-tools/altosui/AltosIgnite.java
ao-tools/altosui/AltosIgniteUI.java
ao-tools/altosui/AltosSerial.java
ao-tools/altosui/AltosTelemetryReader.java
ao-tools/altosui/AltosUI.java

index a0fdb6236cfc3491cfb45abf7eb2d8dba4ab2360..19503dcbe78e5f89c8fcf3fabfa5296f4ffb8188 100644 (file)
@@ -26,7 +26,7 @@ import java.io.*;
 import java.util.*;
 import java.text.*;
 import java.util.prefs.*;
 import java.util.*;
 import java.text.*;
 import java.util.prefs.*;
-import java.util.concurrent.LinkedBlockingQueue;
+import java.util.concurrent.*;
 
 import libaltosJNI.*;
 
 
 import libaltosJNI.*;
 
@@ -123,12 +123,14 @@ public class AltosConfig implements Runnable, ActionListener {
                }
        }
 
                }
        }
 
-       void get_data() throws InterruptedException {
+       void get_data() throws InterruptedException, TimeoutException {
                try {
                        start_serial();
                        serial_line.printf("c s\nv\n");
                        for (;;) {
                try {
                        start_serial();
                        serial_line.printf("c s\nv\n");
                        for (;;) {
-                               String line = serial_line.get_reply();
+                               String line = serial_line.get_reply(1000);
+                               if (line == null)
+                                       throw new TimeoutException();
                                get_int(line, "serial-number", serial);
                                get_int(line, "Main deploy:", main_deploy);
                                get_int(line, "Apogee delay:", apogee_delay);
                                get_int(line, "serial-number", serial);
                                get_int(line, "Main deploy:", main_deploy);
                                get_int(line, "Apogee delay:", apogee_delay);
@@ -147,27 +149,34 @@ public class AltosConfig implements Runnable, ActionListener {
                }
        }
 
                }
        }
 
-       void init_ui () {
+       void init_ui () throws InterruptedException, TimeoutException {
                config_ui = new AltosConfigUI(owner);
                config_ui.addActionListener(this);
                set_ui();
        }
 
                config_ui = new AltosConfigUI(owner);
                config_ui.addActionListener(this);
                set_ui();
        }
 
-       void set_ui() {
-               try {
-                       if (serial_line != null)
-                               get_data();
-                       config_ui.set_serial(serial.get());
-                       config_ui.set_product(product.get());
-                       config_ui.set_version(version.get());
-                       config_ui.set_main_deploy(main_deploy.get());
-                       config_ui.set_apogee_delay(apogee_delay.get());
-                       config_ui.set_radio_channel(radio_channel.get());
-                       config_ui.set_radio_calibration(radio_calibration.get());
-                       config_ui.set_callsign(callsign.get());
-                       config_ui.set_clean();
-               } catch (InterruptedException ie) {
-               }
+       void abort() {
+               JOptionPane.showMessageDialog(owner,
+                                             String.format("Connection to \"%s\" failed",
+                                                           device.toString()),
+                                             "Connection Failed",
+                                             JOptionPane.ERROR_MESSAGE);
+               serial_line.close();
+               serial_line = null;
+       }
+
+       void set_ui() throws InterruptedException, TimeoutException {
+               if (serial_line != null)
+                       get_data();
+               config_ui.set_serial(serial.get());
+               config_ui.set_product(product.get());
+               config_ui.set_version(version.get());
+               config_ui.set_main_deploy(main_deploy.get());
+               config_ui.set_apogee_delay(apogee_delay.get());
+               config_ui.set_radio_channel(radio_channel.get());
+               config_ui.set_radio_calibration(radio_calibration.get());
+               config_ui.set_callsign(callsign.get());
+               config_ui.set_clean();
        }
 
        void run_dialog() {
        }
 
        void run_dialog() {
@@ -198,28 +207,28 @@ public class AltosConfig implements Runnable, ActionListener {
 
        public void actionPerformed(ActionEvent e) {
                String  cmd = e.getActionCommand();
 
        public void actionPerformed(ActionEvent e) {
                String  cmd = e.getActionCommand();
-               if (cmd.equals("Save")) {
-                       save_data();
-                       set_ui();
-               } else if (cmd.equals("Reset")) {
-                       set_ui();
-               } else if (cmd.equals("Reboot")) {
-                       if (serial_line != null) {
-                               try {
+               try {
+                       if (cmd.equals("Save")) {
+                               save_data();
+                               set_ui();
+                       } else if (cmd.equals("Reset")) {
+                               set_ui();
+                       } else if (cmd.equals("Reboot")) {
+                               if (serial_line != null) {
                                        start_serial();
                                        serial_line.printf("r eboot\n");
                                        start_serial();
                                        serial_line.printf("r eboot\n");
-                               } catch (InterruptedException ie) {
-                               } finally {
-                                       try {
-                                               stop_serial();
-                                       } catch (InterruptedException ie) {
-                                       }
+                                       serial_line.flush_output();
+                                       stop_serial();
+                                       serial_line.close();
                                }
                                }
-                               serial_line.close();
+                       } else if (cmd.equals("Close")) {
+                               if (serial_line != null)
+                                       serial_line.close();
                        }
                        }
-               } else if (cmd.equals("Close")) {
-                       if (serial_line != null)
-                               serial_line.close();
+               } catch (InterruptedException ie) {
+                       abort();
+               } catch (TimeoutException te) {
+                       abort();
                }
        }
 
                }
        }
 
@@ -227,8 +236,10 @@ public class AltosConfig implements Runnable, ActionListener {
                try {
                        init_ui();
                        config_ui.make_visible();
                try {
                        init_ui();
                        config_ui.make_visible();
-//             } catch (InterruptedException ie) {
-               } finally {
+               } catch (InterruptedException ie) {
+                       abort();
+               } catch (TimeoutException te) {
+                       abort();
                }
        }
 
                }
        }
 
@@ -255,18 +266,18 @@ public class AltosConfig implements Runnable, ActionListener {
                        } catch (FileNotFoundException ee) {
                                JOptionPane.showMessageDialog(owner,
                                                              String.format("Cannot open device \"%s\"",
                        } catch (FileNotFoundException ee) {
                                JOptionPane.showMessageDialog(owner,
                                                              String.format("Cannot open device \"%s\"",
-                                                                           device.getPath()),
+                                                                           device.toString()),
                                                              "Cannot open target device",
                                                              JOptionPane.ERROR_MESSAGE);
                        } catch (AltosSerialInUseException si) {
                                JOptionPane.showMessageDialog(owner,
                                                              String.format("Device \"%s\" already in use",
                                                              "Cannot open target device",
                                                              JOptionPane.ERROR_MESSAGE);
                        } catch (AltosSerialInUseException si) {
                                JOptionPane.showMessageDialog(owner,
                                                              String.format("Device \"%s\" already in use",
-                                                                           device.getPath()),
+                                                                           device.toString()),
                                                              "Device in use",
                                                              JOptionPane.ERROR_MESSAGE);
                        } catch (IOException ee) {
                                JOptionPane.showMessageDialog(owner,
                                                              "Device in use",
                                                              JOptionPane.ERROR_MESSAGE);
                        } catch (IOException ee) {
                                JOptionPane.showMessageDialog(owner,
-                                                             device.getPath(),
+                                                             device.toString(),
                                                              ee.getLocalizedMessage(),
                                                              JOptionPane.ERROR_MESSAGE);
                        }
                                                              ee.getLocalizedMessage(),
                                                              JOptionPane.ERROR_MESSAGE);
                        }
index 8996b9243a5284cc8a5b2606a6d15abc648e653b..912ff476df8bbb69013db1d872f06384da09ebd8 100644 (file)
@@ -26,7 +26,7 @@ import java.io.*;
 import java.util.*;
 import java.text.*;
 import java.util.prefs.*;
 import java.util.*;
 import java.text.*;
 import java.util.prefs.*;
-import java.util.concurrent.LinkedBlockingQueue;
+import java.util.concurrent.*;
 
 import libaltosJNI.*;
 
 
 import libaltosJNI.*;
 
@@ -78,7 +78,7 @@ public class AltosEepromDownload implements Runnable {
        Thread                  eeprom_thread;
        AltosEepromMonitor      monitor;
 
        Thread                  eeprom_thread;
        AltosEepromMonitor      monitor;
 
-       void CaptureLog() throws IOException, InterruptedException {
+       void CaptureLog() throws IOException, InterruptedException, TimeoutException {
                int                     serial = 0;
                int                     block, state_block = 0;
                int                     addr;
                int                     serial = 0;
                int                     block, state_block = 0;
                int                     addr;
@@ -97,8 +97,10 @@ public class AltosEepromDownload implements Runnable {
                /* Pull the serial number out of the version information */
 
                for (;;) {
                /* Pull the serial number out of the version information */
 
                for (;;) {
-                       String  line = serial_line.get_reply();
+                       String  line = serial_line.get_reply(1000);
 
 
+                       if (line == null)
+                               throw new TimeoutException();
                        if (line.startsWith("serial-number")) {
                                try {
                                        serial = Integer.parseInt(line.substring(13).trim());
                        if (line.startsWith("serial-number")) {
                                try {
                                        serial = Integer.parseInt(line.substring(13).trim());
@@ -125,7 +127,9 @@ public class AltosEepromDownload implements Runnable {
                        any_valid = false;
                        monitor.set_value(state_names[state], state, block - state_block);
                        for (addr = 0; addr < 0x100;) {
                        any_valid = false;
                        monitor.set_value(state_names[state], state, block - state_block);
                        for (addr = 0; addr < 0x100;) {
-                               String  line = serial_line.get_reply();
+                               String  line = serial_line.get_reply(1000);
+                               if (line == null)
+                                       throw new TimeoutException();
                                int[] values = ParseHex(line);
 
                                if (values == null) {
                                int[] values = ParseHex(line);
 
                                if (values == null) {
@@ -228,10 +232,16 @@ public class AltosEepromDownload implements Runnable {
                        CaptureLog();
                } catch (IOException ee) {
                        JOptionPane.showMessageDialog(frame,
                        CaptureLog();
                } catch (IOException ee) {
                        JOptionPane.showMessageDialog(frame,
-                                                     device.getPath(),
+                                                     device.toString(),
                                                      ee.getLocalizedMessage(),
                                                      JOptionPane.ERROR_MESSAGE);
                } catch (InterruptedException ie) {
                                                      ee.getLocalizedMessage(),
                                                      JOptionPane.ERROR_MESSAGE);
                } catch (InterruptedException ie) {
+               } catch (TimeoutException te) {
+                       JOptionPane.showMessageDialog(frame,
+                                                     String.format("Connection to \"%s\" failed",
+                                                                   device.toString()),
+                                                     "Connection Failed",
+                                                     JOptionPane.ERROR_MESSAGE);
                }
                if (remote)
                        serial_line.printf("~");
                }
                if (remote)
                        serial_line.printf("~");
@@ -256,18 +266,18 @@ public class AltosEepromDownload implements Runnable {
                        } catch (FileNotFoundException ee) {
                                JOptionPane.showMessageDialog(frame,
                                                              String.format("Cannot open device \"%s\"",
                        } catch (FileNotFoundException ee) {
                                JOptionPane.showMessageDialog(frame,
                                                              String.format("Cannot open device \"%s\"",
-                                                                           device.getPath()),
+                                                                           device.toString()),
                                                              "Cannot open target device",
                                                              JOptionPane.ERROR_MESSAGE);
                        } catch (AltosSerialInUseException si) {
                                JOptionPane.showMessageDialog(frame,
                                                              String.format("Device \"%s\" already in use",
                                                              "Cannot open target device",
                                                              JOptionPane.ERROR_MESSAGE);
                        } catch (AltosSerialInUseException si) {
                                JOptionPane.showMessageDialog(frame,
                                                              String.format("Device \"%s\" already in use",
-                                                                           device.getPath()),
+                                                                           device.toString()),
                                                              "Device in use",
                                                              JOptionPane.ERROR_MESSAGE);
                        } catch (IOException ee) {
                                JOptionPane.showMessageDialog(frame,
                                                              "Device in use",
                                                              JOptionPane.ERROR_MESSAGE);
                        } catch (IOException ee) {
                                JOptionPane.showMessageDialog(frame,
-                                                             device.getPath(),
+                                                             device.toString(),
                                                              ee.getLocalizedMessage(),
                                                              JOptionPane.ERROR_MESSAGE);
                        }
                                                              ee.getLocalizedMessage(),
                                                              JOptionPane.ERROR_MESSAGE);
                        }
index b09cb59472e0d6c2608161bce26d2f838ae0fdbd..d3b72c67737b507fd6274429614cc6f1641a1138 100644 (file)
@@ -90,7 +90,7 @@ public class AltosFlashUI
                } catch (AltosSerialInUseException si) {
                        JOptionPane.showMessageDialog(frame,
                                                      String.format("Device \"%s\" already in use",
                } catch (AltosSerialInUseException si) {
                        JOptionPane.showMessageDialog(frame,
                                                      String.format("Device \"%s\" already in use",
-                                                                   debug_dongle.getPath()),
+                                                                   debug_dongle.toString()),
                                                      "Device in use",
                                                      JOptionPane.ERROR_MESSAGE);
                } catch (IOException e) {
                                                      "Device in use",
                                                      JOptionPane.ERROR_MESSAGE);
                } catch (IOException e) {
index 5c27e8fafbcf5f3935046b82c257baa0cacf4e69..8e92ec1b71531df85a3bdb210521a380876338e4 100644 (file)
@@ -18,6 +18,7 @@
 package altosui;
 
 import java.io.*;
 package altosui;
 
 import java.io.*;
+import java.util.concurrent.*;
 
 public class AltosIgnite {
        AltosDevice     device;
 
 public class AltosIgnite {
        AltosDevice     device;
@@ -91,35 +92,40 @@ public class AltosIgnite {
                return Unknown;
        }
 
                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();
                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;
        }
 
                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;
        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;
        public AltosIgnite(AltosDevice in_device) throws FileNotFoundException, AltosSerialInUseException {
 
                device = in_device;
-               serial = null;
-//             serial = new AltosSerial(device);
+               serial = new AltosSerial(device);
                remote = false;
 
                remote = false;
 
-//             if (!device.matchProduct(AltosDevice.product_telemetrum))
-//                     remote = true;
+               if (!device.matchProduct(AltosDevice.product_telemetrum))
+                       remote = true;
        }
 }
\ No newline at end of file
        }
 }
\ No newline at end of file
index 62da413cd553dd4d6e911ed8e889aa0cf8829ce3..caecc3ef8fd7d392ec12cceac33ace39897089a2 100644 (file)
@@ -27,22 +27,31 @@ import java.io.*;
 import java.util.*;
 import java.text.*;
 import java.util.prefs.*;
 import java.util.*;
 import java.text.*;
 import java.util.prefs.*;
+import java.util.concurrent.*;
 
 public class AltosIgniteUI
        extends JDialog
        implements ActionListener
 {
 
 public class AltosIgniteUI
        extends JDialog
        implements ActionListener
 {
+       AltosDevice     device;
+       AltosIgnite     ignite;
        JFrame          owner;
        JLabel          label;
        JRadioButton    apogee;
        JFrame          owner;
        JLabel          label;
        JRadioButton    apogee;
+       JLabel          apogee_status_label;
        JRadioButton    main;
        JRadioButton    main;
+       JLabel          main_status_label;
        JToggleButton   arm;
        JButton         fire;
        javax.swing.Timer       timer;
 
        JToggleButton   arm;
        JButton         fire;
        javax.swing.Timer       timer;
 
+       int             apogee_status;
+       int             main_status;
+
        final static int        timeout = 1 * 1000;
 
        int             time_remaining;
        final static int        timeout = 1 * 1000;
 
        int             time_remaining;
+       boolean         timer_running;
 
        void set_arm_text() {
                if (arm.isSelected())
 
        void set_arm_text() {
                if (arm.isSelected())
@@ -54,7 +63,7 @@ public class AltosIgniteUI
        void start_timer() {
                time_remaining = 10;
                set_arm_text();
        void start_timer() {
                time_remaining = 10;
                set_arm_text();
-               timer.restart();
+               timer_running = true;
        }
 
        void stop_timer() {
        }
 
        void stop_timer() {
@@ -62,7 +71,7 @@ public class AltosIgniteUI
                arm.setSelected(false);
                arm.setEnabled(false);
                fire.setEnabled(false);
                arm.setSelected(false);
                arm.setEnabled(false);
                fire.setEnabled(false);
-               timer.stop();
+               timer_running = false;
                set_arm_text();
        }
 
                set_arm_text();
        }
 
@@ -73,12 +82,47 @@ public class AltosIgniteUI
                stop_timer();
        }
 
                stop_timer();
        }
 
+       void get_ignite_status() throws InterruptedException, TimeoutException {
+               apogee_status = ignite.status(AltosIgnite.Apogee);
+               main_status = ignite.status(AltosIgnite.Main);
+       }
+
+       void set_ignite_status() throws InterruptedException, TimeoutException {
+               get_ignite_status();
+               apogee_status_label.setText(String.format("\"%s\"", ignite.status_string(apogee_status)));
+               main_status_label.setText(String.format("\"%s\"", ignite.status_string(main_status)));
+       }
+
+       void close() {
+               timer.stop();
+               setVisible(false);
+               ignite.close();
+       }
+
+       void abort() {
+               close();
+               JOptionPane.showMessageDialog(owner,
+                                             String.format("Connection to \"%s\" failed",
+                                                           device.toString()),
+                                             "Connection Failed",
+                                             JOptionPane.ERROR_MESSAGE);
+       }
+
        void tick_timer() {
        void tick_timer() {
-               --time_remaining;
-               if (time_remaining <= 0)
-                       cancel();
-               else
-                       set_arm_text();
+               if (timer_running) {
+                       --time_remaining;
+                       if (time_remaining <= 0)
+                               cancel();
+                       else
+                               set_arm_text();
+               }
+               try {
+                       set_ignite_status();
+               } catch (InterruptedException ie) {
+                       abort();
+               } catch (TimeoutException te) {
+                       abort();
+               }
        }
 
        void fire() {
        }
 
        void fire() {
@@ -88,7 +132,7 @@ public class AltosIgniteUI
                                igniter = AltosIgnite.Apogee;
                        else if (main.isSelected() && !apogee.isSelected())
                                igniter = AltosIgnite.Main;
                                igniter = AltosIgnite.Apogee;
                        else if (main.isSelected() && !apogee.isSelected())
                                igniter = AltosIgnite.Main;
-                       System.out.printf ("fire %d\n", igniter);
+                       ignite.fire(igniter);
                        cancel();
                }
        }
                        cancel();
                }
        }
@@ -97,13 +141,18 @@ public class AltosIgniteUI
                String cmd = e.getActionCommand();
                if (cmd.equals("apogee") || cmd.equals("main")) {
                        stop_timer();
                String cmd = e.getActionCommand();
                if (cmd.equals("apogee") || cmd.equals("main")) {
                        stop_timer();
-                       arm.setEnabled(true);
                }
 
                }
 
-               if (cmd.equals("apogee") && apogee.isSelected())
+               if (cmd.equals("apogee") && apogee.isSelected()) {
                        main.setSelected(false);
                        main.setSelected(false);
-               if (cmd.equals("main") && main.isSelected())
+                       if (apogee_status == AltosIgnite.Ready)
+                               arm.setEnabled(true);
+               }
+               if (cmd.equals("main") && main.isSelected()) {
                        apogee.setSelected(false);
                        apogee.setSelected(false);
+                       if (main_status == AltosIgnite.Ready)
+                               arm.setEnabled(true);
+               }
 
                if (cmd.equals("arm")) {
                        if (arm.isSelected()) {
 
                if (cmd.equals("arm")) {
                        if (arm.isSelected()) {
@@ -116,15 +165,71 @@ public class AltosIgniteUI
                        fire();
                if (cmd.equals("tick"))
                        tick_timer();
                        fire();
                if (cmd.equals("tick"))
                        tick_timer();
+               if (cmd.equals("close")) {
+                       close();
+               }
+       }
+
+       /* A window listener to catch closing events and tell the config code */
+       class ConfigListener extends WindowAdapter {
+               AltosIgniteUI   ui;
+
+               public ConfigListener(AltosIgniteUI this_ui) {
+                       ui = this_ui;
+               }
+
+               public void windowClosing(WindowEvent e) {
+                       ui.actionPerformed(new ActionEvent(e.getSource(),
+                                                          ActionEvent.ACTION_PERFORMED,
+                                                          "close"));
+               }
+       }
+
+       private boolean open() {
+               device = AltosDeviceDialog.show(owner, AltosDevice.product_any);
+               if (device != null) {
+                       try {
+                               ignite = new AltosIgnite(device);
+                               return true;
+                       } catch (FileNotFoundException ee) {
+                               JOptionPane.showMessageDialog(owner,
+                                                             String.format("Cannot open device \"%s\"",
+                                                                           device.toString()),
+                                                             "Cannot open target device",
+                                                             JOptionPane.ERROR_MESSAGE);
+                       } catch (AltosSerialInUseException si) {
+                               JOptionPane.showMessageDialog(owner,
+                                                             String.format("Device \"%s\" already in use",
+                                                                           device.toString()),
+                                                             "Device in use",
+                                                             JOptionPane.ERROR_MESSAGE);
+                       } catch (IOException ee) {
+                               JOptionPane.showMessageDialog(owner,
+                                                             device.toString(),
+                                                             ee.getLocalizedMessage(),
+                                                             JOptionPane.ERROR_MESSAGE);
+                       }
+               }
+               return false;
        }
 
        public AltosIgniteUI(JFrame in_owner) {
        }
 
        public AltosIgniteUI(JFrame in_owner) {
+
+               owner = in_owner;
+               apogee_status = AltosIgnite.Unknown;
+               main_status = AltosIgnite.Unknown;
+
+               if (!open())
+                       return;
+
                Container               pane = getContentPane();
                GridBagConstraints      c = new GridBagConstraints();
                Insets                  i = new Insets(4,4,4,4);
 
                timer = new javax.swing.Timer(timeout, this);
                timer.setActionCommand("tick");
                Container               pane = getContentPane();
                GridBagConstraints      c = new GridBagConstraints();
                Insets                  i = new Insets(4,4,4,4);
 
                timer = new javax.swing.Timer(timeout, this);
                timer.setActionCommand("tick");
+               timer_running = false;
+               timer.restart();
 
                owner = in_owner;
 
 
                owner = in_owner;
 
@@ -139,12 +244,14 @@ public class AltosIgniteUI
                c.gridx = 0;
                c.gridy = 0;
                c.gridwidth = 2;
                c.gridx = 0;
                c.gridy = 0;
                c.gridwidth = 2;
+               c.anchor = GridBagConstraints.CENTER;
                label = new JLabel ("Fire Igniter");
                pane.add(label, c);
 
                c.gridx = 0;
                c.gridy = 1;
                c.gridwidth = 1;
                label = new JLabel ("Fire Igniter");
                pane.add(label, c);
 
                c.gridx = 0;
                c.gridy = 1;
                c.gridwidth = 1;
+               c.anchor = GridBagConstraints.WEST;
                apogee = new JRadioButton ("Apogee");
                pane.add(apogee, c);
                apogee.addActionListener(this);
                apogee = new JRadioButton ("Apogee");
                pane.add(apogee, c);
                apogee.addActionListener(this);
@@ -153,14 +260,40 @@ public class AltosIgniteUI
                c.gridx = 1;
                c.gridy = 1;
                c.gridwidth = 1;
                c.gridx = 1;
                c.gridy = 1;
                c.gridwidth = 1;
+               c.anchor = GridBagConstraints.WEST;
+               apogee_status_label = new JLabel();
+               pane.add(apogee_status_label, c);
+
+               c.gridx = 0;
+               c.gridy = 2;
+               c.gridwidth = 1;
+               c.anchor = GridBagConstraints.WEST;
                main = new JRadioButton ("Main");
                pane.add(main, c);
                main.addActionListener(this);
                main.setActionCommand("main");
 
                main = new JRadioButton ("Main");
                pane.add(main, c);
                main.addActionListener(this);
                main.setActionCommand("main");
 
-               c.gridx = 0;
+               c.gridx = 1;
                c.gridy = 2;
                c.gridwidth = 1;
                c.gridy = 2;
                c.gridwidth = 1;
+               c.anchor = GridBagConstraints.WEST;
+               main_status_label = new JLabel();
+               pane.add(main_status_label, c);
+
+               try {
+                       set_ignite_status();
+               } catch (InterruptedException ie) {
+                       abort();
+                       return;
+               } catch (TimeoutException te) {
+                       abort();
+                       return;
+               }
+
+               c.gridx = 0;
+               c.gridy = 3;
+               c.gridwidth = 1;
+               c.anchor = GridBagConstraints.CENTER;
                arm = new JToggleButton ("Arm");
                pane.add(arm, c);
                arm.addActionListener(this);
                arm = new JToggleButton ("Arm");
                pane.add(arm, c);
                arm.addActionListener(this);
@@ -168,8 +301,9 @@ public class AltosIgniteUI
                arm.setEnabled(false);
 
                c.gridx = 1;
                arm.setEnabled(false);
 
                c.gridx = 1;
-               c.gridy = 2;
+               c.gridy = 3;
                c.gridwidth = 1;
                c.gridwidth = 1;
+               c.anchor = GridBagConstraints.CENTER;
                fire = new JButton ("Fire");
                fire.setEnabled(false);
                pane.add(fire, c);
                fire = new JButton ("Fire");
                fire.setEnabled(false);
                pane.add(fire, c);
@@ -179,5 +313,7 @@ public class AltosIgniteUI
                pack();
                setLocationRelativeTo(owner);
                setVisible(true);
                pack();
                setLocationRelativeTo(owner);
                setVisible(true);
+
+               addWindowListener(new ConfigListener(this));
        }
 }
\ No newline at end of file
        }
 }
\ No newline at end of file
index 99a92fdba5153c69aa8569de3a21012220172a43..0d32a5ae851807e0940a634acf7ccfef335030cd 100644 (file)
@@ -132,6 +132,14 @@ public class AltosSerial implements Runnable {
                return line.line;
        }
 
                return line.line;
        }
 
+       public String get_reply(int timeout) throws InterruptedException {
+               flush_output();
+               AltosLine line = reply_queue.poll(timeout, TimeUnit.MILLISECONDS);
+               if (line == null)
+                       return null;
+               return line.line;
+       }
+
        public void add_monitor(LinkedBlockingQueue<AltosLine> q) {
                set_monitor(true);
                monitors.add(q);
        public void add_monitor(LinkedBlockingQueue<AltosLine> q) {
                set_monitor(true);
                monitors.add(q);
@@ -185,10 +193,9 @@ public class AltosSerial implements Runnable {
                                throw new AltosSerialInUseException(device);
                        devices_opened.add(device.getPath());
                }
                                throw new AltosSerialInUseException(device);
                        devices_opened.add(device.getPath());
                }
-               close();
                altos = libaltos.altos_open(device);
                if (altos == null)
                altos = libaltos.altos_open(device);
                if (altos == null)
-                       throw new FileNotFoundException(device.getPath());
+                       throw new FileNotFoundException(device.toString());
                input_thread = new Thread(this);
                input_thread.start();
                print("~\nE 0\n");
                input_thread = new Thread(this);
                input_thread.start();
                print("~\nE 0\n");
index ff02c7225c00762b1516e420edb778d7317fe89b..379e0e67466b7e402d1e35e2bf07a7c7263348e1 100644 (file)
@@ -55,7 +55,7 @@ class AltosTelemetryReader extends AltosFlightReader {
                device = in_device;
                serial = new AltosSerial(device);
                log = new AltosLog(serial);
                device = in_device;
                serial = new AltosSerial(device);
                log = new AltosLog(serial);
-               name = device.getPath();
+               name = device.toString();
 
                telem = new LinkedBlockingQueue<AltosLine>();
                serial.add_monitor(telem);
 
                telem = new LinkedBlockingQueue<AltosLine>();
                serial.add_monitor(telem);
index c82c8e8a08b2dcacc42512ff61e2ba79e8cf7199..b573ef7f7280a6de77cc825b2b4f67fad025abf9 100644 (file)
@@ -53,18 +53,18 @@ public class AltosUI extends JFrame {
                } catch (FileNotFoundException ee) {
                        JOptionPane.showMessageDialog(AltosUI.this,
                                                      String.format("Cannot open device \"%s\"",
                } catch (FileNotFoundException ee) {
                        JOptionPane.showMessageDialog(AltosUI.this,
                                                      String.format("Cannot open device \"%s\"",
-                                                                   device.getPath()),
+                                                                   device.toString()),
                                                      "Cannot open target device",
                                                      JOptionPane.ERROR_MESSAGE);
                } catch (AltosSerialInUseException si) {
                        JOptionPane.showMessageDialog(AltosUI.this,
                                                      String.format("Device \"%s\" already in use",
                                                      "Cannot open target device",
                                                      JOptionPane.ERROR_MESSAGE);
                } catch (AltosSerialInUseException si) {
                        JOptionPane.showMessageDialog(AltosUI.this,
                                                      String.format("Device \"%s\" already in use",
-                                                                   device.getPath()),
+                                                                   device.toString()),
                                                      "Device in use",
                                                      JOptionPane.ERROR_MESSAGE);
                } catch (IOException ee) {
                        JOptionPane.showMessageDialog(AltosUI.this,
                                                      "Device in use",
                                                      JOptionPane.ERROR_MESSAGE);
                } catch (IOException ee) {
                        JOptionPane.showMessageDialog(AltosUI.this,
-                                                     device.getPath(),
+                                                     device.toString(),
                                                      "Unkonwn I/O error",
                                                      JOptionPane.ERROR_MESSAGE);
                }
                                                      "Unkonwn I/O error",
                                                      JOptionPane.ERROR_MESSAGE);
                }