X-Git-Url: https://git.gag.com/?p=fw%2Faltos;a=blobdiff_plain;f=altoslib%2FAltosEepromRecordSet.java;h=360759314d4bf9e123bf2e109271f66beb6375ff;hp=000d9c02a848d03b3a793ba5c9426e3341e44e56;hb=57218127ee39724e985fefcf203991401f01cc84;hpb=e67a5c6ffa7174d66e985483fab4bf52ccaea5ca diff --git a/altoslib/AltosEepromRecordSet.java b/altoslib/AltosEepromRecordSet.java index 000d9c02..36075931 100644 --- a/altoslib/AltosEepromRecordSet.java +++ b/altoslib/AltosEepromRecordSet.java @@ -12,46 +12,49 @@ * General Public License for more details. */ -package org.altusmetrum.altoslib_11; +package org.altusmetrum.altoslib_12; import java.io.*; import java.util.*; -public class AltosEepromRecordSet implements Iterable { +public class AltosEepromRecordSet implements AltosRecordSet { + AltosEeprom eeprom; TreeSet ordered; - AltosState start_state; + AltosCalData cal_data; - class RecordIterator implements Iterator { - Iterator riterator; - AltosState state; - boolean started; - - public boolean hasNext() { - return state == null || riterator.hasNext(); - } + public AltosConfigData config_data() { + return eeprom.config_data(); + } - public AltosState next() { - if (state == null) - state = start_state.clone(); - else { - state = state.clone(); - AltosEepromRecord r = riterator.next(); - r.update_state(state); + public AltosCalData cal_data() { + if (cal_data == null) { + cal_data = new AltosCalData(config_data()); + for (AltosEepromRecord record : ordered) { + if (record.cmd() == AltosLib.AO_LOG_FLIGHT) { + cal_data.set_tick(record.tick()); + cal_data.set_boost_tick(); + break; + } } - return state; } + return cal_data; + } + + public void capture_series(AltosDataListener listener) { + AltosCalData cal_data = cal_data(); - public RecordIterator() { - riterator = ordered.iterator(); - state = null; + cal_data.reset(); + listener.set_log_format(config_data().log_format); + + for (AltosEepromRecord record : ordered) { + record.provide_data(listener, cal_data); } + listener.finish(); } - public Iterator iterator() { - return new RecordIterator(); - } + public AltosEepromRecordSet(AltosEeprom eeprom) { + this.eeprom = eeprom; - public AltosEepromRecordSet(AltosEepromNew eeprom) { AltosConfigData config_data = eeprom.config_data(); AltosEepromRecord record = null; @@ -66,6 +69,7 @@ public class AltosEepromRecordSet implements Iterable { case AltosLib.AO_LOG_FORMAT_TELEMETRY: case AltosLib.AO_LOG_FORMAT_TELESCIENCE: case AltosLib.AO_LOG_FORMAT_TELEMEGA: + case AltosLib.AO_LOG_FORMAT_TELEMEGA_3: case AltosLib.AO_LOG_FORMAT_TELEMEGA_OLD: record = new AltosEepromRecordMega(eeprom); break; @@ -74,7 +78,8 @@ public class AltosEepromRecordSet implements Iterable { break; case AltosLib.AO_LOG_FORMAT_TELEMINI2: case AltosLib.AO_LOG_FORMAT_TELEMINI3: - case AltosLib.AO_LOG_FORMAT_EASYMINI: + case AltosLib.AO_LOG_FORMAT_EASYMINI1: + case AltosLib.AO_LOG_FORMAT_EASYMINI2: record = new AltosEepromRecordMini(eeprom); break; case AltosLib.AO_LOG_FORMAT_TELEGPS: @@ -93,10 +98,7 @@ public class AltosEepromRecordSet implements Iterable { int tick = 0; boolean first = true; - start_state = new AltosState(); - start_state.set_config_data(record.eeprom.config_data()); - - for (;;) { + do { int t = record.tick(); if (first) { @@ -109,13 +111,11 @@ public class AltosEepromRecordSet implements Iterable { } record.wide_tick = tick; ordered.add(record); - if (!record.hasNext()) - break; record = record.next(); - } + } while (record != null); } - public AltosEepromRecordSet(Reader input) throws IOException { - this(new AltosEepromNew(input)); + public AltosEepromRecordSet(InputStream input) throws IOException { + this(new AltosEeprom(input)); } }