package org.altusmetrum.AltosLib;
import java.io.*;
-import java.lang.*;
-import java.util.*;
import java.text.ParseException;
import java.util.concurrent.LinkedBlockingQueue;
* This creates a thread to capture telemetry data and write it to
* a log file
*/
-class AltosLog implements Runnable {
+public class AltosLog implements Runnable {
LinkedBlockingQueue<AltosLine> input_queue;
LinkedBlockingQueue<String> pending_queue;
}
}
- void close() {
+ public void close() {
close_log_file();
if (log_thread != null) {
log_thread.interrupt();
}
}
- File file() {
+ public File file() {
return file;
}
boolean open (AltosRecord telem) throws IOException {
AltosFile a = new AltosFile(telem);
- System.out.printf("open %s\n", a.toString());
log_file = new FileWriter(a, true);
if (log_file != null) {
while (!pending_queue.isEmpty()) {
continue;
try {
AltosRecord telem = AltosTelemetry.parse(line.line, previous);
- if (telem.serial != 0 && telem.flight != 0 &&
+ if ((telem.seen & AltosRecord.seen_flight) != 0 &&
(telem.serial != serial || telem.flight != flight || log_file == null))
{
close_log_file();