altosui: Add KML file export.
[fw/altos] / ao-tools / altosui / AltosLog.java
1 /*
2  * Copyright © 2010 Keith Packard <keithp@keithp.com>
3  *
4  * This program is free software; you can redistribute it and/or modify
5  * it under the terms of the GNU General Public License as published by
6  * the Free Software Foundation; version 2 of the License.
7  *
8  * This program is distributed in the hope that it will be useful, but
9  * WITHOUT ANY WARRANTY; without even the implied warranty of
10  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
11  * General Public License for more details.
12  *
13  * You should have received a copy of the GNU General Public License along
14  * with this program; if not, write to the Free Software Foundation, Inc.,
15  * 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA.
16  */
17
18 package altosui;
19
20 import java.io.*;
21 import java.lang.*;
22 import java.util.*;
23 import java.text.ParseException;
24 import java.util.concurrent.LinkedBlockingQueue;
25 import altosui.AltosSerial;
26 import altosui.AltosFile;
27 import altosui.AltosLine;
28
29 /*
30  * This creates a thread to capture telemetry data and write it to
31  * a log file
32  */
33 class AltosLog implements Runnable {
34
35         LinkedBlockingQueue<AltosLine>  input_queue;
36         LinkedBlockingQueue<String>     pending_queue;
37         int                             serial;
38         int                             flight;
39         FileWriter                      log_file;
40         Thread                          log_thread;
41
42         void close() throws IOException {
43                 if (log_file != null)
44                         log_file.close();
45         }
46
47         boolean open (AltosTelemetry telem) throws IOException {
48                 AltosFile       a = new AltosFile(telem);
49
50                 log_file = new FileWriter(a, true);
51                 if (log_file != null) {
52                         while (!pending_queue.isEmpty()) {
53                                 try {
54                                         String s = pending_queue.take();
55                                         log_file.write(s);
56                                         log_file.write('\n');
57                                 } catch (InterruptedException ie) {
58                                 }
59                         }
60                         log_file.flush();
61                 }
62                 return log_file != null;
63         }
64
65         public void run () {
66                 try {
67                         for (;;) {
68                                 AltosLine       line = input_queue.take();
69                                 if (line.line == null)
70                                         continue;
71                                 try {
72                                         AltosTelemetry  telem = new AltosTelemetry(line.line);
73                                         if (telem.serial != serial || telem.flight != flight || log_file == null) {
74                                                 close();
75                                                 serial = telem.serial;
76                                                 flight = telem.flight;
77                                                 open(telem);
78                                         }
79                                 } catch (ParseException pe) {
80                                 } catch (AltosCRCException ce) {
81                                 }
82                                 if (log_file != null) {
83                                         log_file.write(line.line);
84                                         log_file.write('\n');
85                                         log_file.flush();
86                                 } else
87                                         pending_queue.put(line.line);
88                         }
89                 } catch (InterruptedException ie) {
90                 } catch (IOException ie) {
91                 }
92                 try {
93                         close();
94                 } catch (IOException ie) {
95                 }
96         }
97
98         public AltosLog (AltosSerial s) {
99                 pending_queue = new LinkedBlockingQueue<String> ();
100                 input_queue = new LinkedBlockingQueue<AltosLine> ();
101                 s.add_monitor(input_queue);
102                 serial = -1;
103                 flight = -1;
104                 log_file = null;
105                 log_thread = new Thread(this);
106                 log_thread.start();
107         }
108 }