adds initial version of FTR reader

plugins/com.minres.scviewer.database.ftr/src/com/minres/scviewer/database/ftr/AbstractTxStream.java

@@ -0,0 +1,190 @@
+/*******************************************************************************
+ * Copyright (c) 2012 IT Just working
+ * Copyright (c) 2020 MINRES Technologies GmbH
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ *     IT Just working - initial API and implementation
+ *******************************************************************************/
+package com.minres.scviewer.database.ftr;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+
+import com.minres.scviewer.database.EventEntry;
+import com.minres.scviewer.database.EventList;
+import com.minres.scviewer.database.HierNode;
+import com.minres.scviewer.database.IEvent;
+import com.minres.scviewer.database.IEventList;
+import com.minres.scviewer.database.IWaveform;
+import com.minres.scviewer.database.WaveformType;
+import com.minres.scviewer.database.tx.ITx;
+import com.minres.scviewer.database.tx.ITxEvent;
+
+/**
+ * The Class AbstractTxStream.
+ */
+abstract class AbstractTxStream extends HierNode implements IWaveform {
+
+	private final String fullName;
+
+	/** The id. */
+	private Long id;
+
+	/** The loader. */
+	protected FtrDbLoader loader;
+
+	/** The events. */
+	IEventList events = new EventList();
+
+	/** The max concurrency. */
+	private int rowCount = -1;
+
+	/**
+	 * Instantiates a new abstract tx stream.
+	 *
+	 * @param loader the loader
+	 * @param id     the id
+	 * @param name   the name
+	 */
+	protected AbstractTxStream(FtrDbLoader loader, Long id, String name) {
+		super(name);
+		fullName=name;
+		this.loader = loader;
+		this.id = id;
+	}
+
+	/**
+	 * Gets the full hierarchical name.
+	 *
+	 * @return the full name
+	 */
+	@Override
+	public String getFullName() {
+		return  fullName;
+	}
+	/**
+	 * Adds the event.
+	 *
+	 * @param evt the evt
+	 */
+	public void addEvent(ITxEvent evt) {
+		events.put(evt.getTime(), evt);
+	}
+
+	/**
+	 * Gets the events.
+	 *
+	 * @return the events
+	 */
+	@Override
+	public IEventList getEvents() {
+		return events;
+	}
+
+	/**
+	 * Gets the events at time.
+	 *
+	 * @param time the time
+	 * @return the events at time
+	 */
+	@Override
+	public IEvent[] getEventsAtTime(long time) {
+		return events.get(time);
+	}
+
+	/**
+	 * Gets the events before time.
+	 *
+	 * @param time the time
+	 * @return the events before time
+	 */
+	@Override
+	public IEvent[] getEventsBeforeTime(long time) {
+		EventEntry e = events.floorEntry(time);
+		if (e == null)
+			return new IEvent[] {};
+		else
+			return events.floorEntry(time).events;
+	}
+
+	/**
+	 * Gets the type.
+	 *
+	 * @return the type
+	 */
+	@Override
+	public WaveformType getType() {
+		return WaveformType.TRANSACTION;
+	}
+
+	/**
+	 * Gets the id.
+	 *
+	 * @return the id
+	 */
+	@Override
+	public long getId() {
+		return id;
+	}
+
+	/**
+	 * Gets the width.
+	 *
+	 * @return the width
+	 */
+	@Override
+	public int getRowCount() {
+		if (rowCount<0)
+			calculateConcurrency();
+		return rowCount;
+	}
+
+	/**
+	 * Calculate concurrency.
+	 */
+	void calculateConcurrency() {
+		if (rowCount>=0)
+			return;
+		ArrayList<Long> rowEndTime = new ArrayList<>();
+		HashMap<Long, Integer> rowByTxId = new HashMap<>();
+		for(EventEntry entry: events) {
+			for(IEvent evt:entry.events) {
+				TxEvent txEvt = (TxEvent) evt;
+				ITx tx = txEvt.getTransaction();
+				int rowIdx = 0;
+				switch(evt.getKind()) {
+				case END: //TODO: might throw NPE in concurrent execution
+					Long txId = txEvt.getTransaction().getId();
+					txEvt.setConcurrencyIndex(rowByTxId.get(txId));
+					rowByTxId.remove(txId);
+					break;
+				case SINGLE:
+					for (; rowIdx < rowEndTime.size() && rowEndTime.get(rowIdx)>tx.getBeginTime(); rowIdx++);
+					if (rowEndTime.size() <= rowIdx)
+						rowEndTime.add(tx.getEndTime());
+					else
+						rowEndTime.set(rowIdx, tx.getEndTime());
+					((TxEvent) evt).setConcurrencyIndex(rowIdx);
+					break;
+				case BEGIN:
+					for (; rowIdx < rowEndTime.size() && rowEndTime.get(rowIdx)>tx.getBeginTime(); rowIdx++);
+					if (rowEndTime.size() <= rowIdx)
+						rowEndTime.add(tx.getEndTime());
+					else
+						rowEndTime.set(rowIdx, tx.getEndTime());
+					((TxEvent) evt).setConcurrencyIndex(rowIdx);
+					rowByTxId.put(tx.getId(), rowIdx);
+					break;
+				}
+			}
+		}
+		rowCount=rowEndTime.size()>0?rowEndTime.size():1;
+		//getChildNodes().parallelStream().forEach(c -> ((TxGenerator)c).calculateConcurrency());
+		getChildNodes().stream().forEach(c -> ((TxGenerator)c).calculateConcurrency());
+	}
+
+}

plugins/com.minres.scviewer.database.ftr/src/com/minres/scviewer/database/ftr/FtrDbLoader.java

@@ -0,0 +1,475 @@
+/*******************************************************************************
+ * Copyright (c) 2012 IT Just working.
+ * Copyright (c) 2020 MINRES Technologies GmbH
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ *     IT Just working - initial API and implementation
+ *******************************************************************************/
+package com.minres.scviewer.database.ftr;
+
+import java.beans.PropertyChangeListener;
+import java.beans.PropertyChangeSupport;
+import java.io.ByteArrayInputStream;
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.nio.channels.FileChannel;
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.TreeMap;
+
+import org.eclipse.collections.impl.map.mutable.UnifiedMap;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import com.google.common.collect.HashMultimap;
+import com.minres.scviewer.database.AssociationType;
+import com.minres.scviewer.database.DataType;
+import com.minres.scviewer.database.EventKind;
+import com.minres.scviewer.database.IWaveform;
+import com.minres.scviewer.database.IWaveformDb;
+import com.minres.scviewer.database.IWaveformDbLoader;
+import com.minres.scviewer.database.InputFormatException;
+import com.minres.scviewer.database.RelationType;
+import com.minres.scviewer.database.RelationTypeFactory;
+import com.minres.scviewer.database.tx.ITx;
+import com.minres.scviewer.database.tx.ITxAttribute;
+import com.minres.scviewer.database.RelationType;
+
+import jacob.CborDecoder;
+import jacob.CborType;
+
+/**
+ * The Class TextDbLoader.
+ */
+public class FtrDbLoader implements IWaveformDbLoader {
+
+	enum FileType { NONE, PLAIN, GZIP, LZ4};
+
+	/** The max time. */
+	private Long maxTime = 0L;
+
+	ArrayList<String> strDict = new ArrayList<>();
+
+
+	/** The attr values. */
+	final List<String> attrValues = new ArrayList<>();
+
+	/** The relation types. */
+	final Map<String, RelationType> relationTypes = UnifiedMap.newMap();
+
+	/** The tx streams. */
+	final Map<Long, TxStream> txStreams = UnifiedMap.newMap();
+
+	/** The tx generators. */
+	final Map<Long, TxGenerator> txGenerators = UnifiedMap.newMap();
+
+	/** The transactions. */
+	final Map<Long, FtrTx> transactions = UnifiedMap.newMap();
+
+	/** The attribute types. */
+	final Map<String, TxAttributeType> attributeTypes = UnifiedMap.newMap();
+
+	/** The relations in. */
+	final HashMultimap<Long, FtrRelation> relationsIn = HashMultimap.create();
+
+	/** The relations out. */
+	final HashMultimap<Long, FtrRelation> relationsOut = HashMultimap.create();
+
+	/** The tx cache. */
+	final Map<Long, Tx> txCache = UnifiedMap.newMap();
+
+	/** The threads. */
+	List<Thread> threads = new ArrayList<>();
+
+	File file;
+	
+	private static final Logger LOG = LoggerFactory.getLogger(FtrDbLoader.class);
+	
+	/** The pcs. */
+	protected PropertyChangeSupport pcs = new PropertyChangeSupport(this);
+
+	/** The Constant x. */
+	static final byte[] x = "scv_tr_stream".getBytes();
+
+	/**
+	 * Adds the property change listener.
+	 *
+	 * @param l the l
+	 */
+	@Override
+	public void addPropertyChangeListener(PropertyChangeListener l) {
+		pcs.addPropertyChangeListener(l);
+	}
+
+	/**
+	 * Removes the property change listener.
+	 *
+	 * @param l the l
+	 */
+	@Override
+	public void removePropertyChangeListener(PropertyChangeListener l) {
+		pcs.removePropertyChangeListener(l);
+	}
+
+	/**
+	 * Gets the max time.
+	 *
+	 * @return the max time
+	 */
+	@Override
+	public long getMaxTime() {
+		return maxTime;
+	}
+
+	/**
+	 * Gets the transaction.
+	 *
+	 * @param txId the tx id
+	 * @return the transaction
+	 */
+	public ITx getTransaction(long txId) {
+		if (txCache.containsKey(txId))
+			return txCache.get(txId);
+		if(transactions.containsKey(txId)) {
+			Tx tx = new Tx(this, transactions.get(txId));
+			txCache.put(txId, tx);
+			return tx;
+		} else {
+			throw new IllegalArgumentException();
+		}
+	}
+
+	public FtrTx getScvTx(long id) {
+		if(transactions.containsKey(id))
+			return transactions.get(id);
+		else
+			throw new IllegalArgumentException();
+	}
+
+	/**
+	 * Gets the all waves.
+	 *
+	 * @return the all waves
+	 */
+	@Override
+	public Collection<IWaveform> getAllWaves() {
+		ArrayList<IWaveform> ret =  new ArrayList<>(txStreams.values());
+		ret.addAll(txGenerators.values());
+		return ret;
+	}
+
+	/**
+	 * Gets the all relation types.
+	 *
+	 * @return the all relation types
+	 */
+	public Collection<RelationType> getAllRelationTypes() {
+		return relationTypes.values();
+	}
+
+	/**
+	 * Load.
+	 *
+	 * @param db   the db
+	 * @param file the file
+	 * @return true, if successful
+	 * @throws InputFormatException the input format exception
+	 */
+	@Override
+	public void load(IWaveformDb db, File file) throws InputFormatException {
+		dispose();
+		this.file=file;
+		try(FileInputStream fis = new FileInputStream(file)) {
+			new CborDbParser(this, fis);
+		} catch (Exception e) {
+			LOG.error("Error parsing file "+file.getName(), e);
+			transactions.clear();
+			throw new InputFormatException(e.toString());
+		}
+		txStreams.values().parallelStream().forEach(TxStream::calculateConcurrency);
+	}
+
+	public List<? extends byte[]> getChunksAtOffsets(ArrayList<Long> fileOffsets) throws InputFormatException {
+		List<byte[]> ret = new ArrayList<>();
+		try(FileInputStream fis = new FileInputStream(file)) {
+			FileChannel fc = fis.getChannel();
+			for (Long offset : fileOffsets) {
+				fc.position(offset);
+				CborDecoder parser = new CborDecoder(fis);
+				ret.add(parser.readByteString());
+			}
+		} catch (Exception e) {
+			LOG.error("Error parsing file "+file.getName(), e);
+			transactions.clear();
+			throw new InputFormatException(e.toString());
+		}
+		return ret;
+	}
+
+	public List<? extends ITxAttribute> parseAtrributes(byte[] chunk, long blockOffset) {
+		List<ITxAttribute> ret = new ArrayList<>();
+		ByteArrayInputStream bais = new ByteArrayInputStream(chunk);
+		bais.skip(blockOffset);
+		CborDecoder cborDecoder = new CborDecoder(bais);
+		try {
+			long tx_size = cborDecoder.readArrayLength();
+			for(long i = 0; i<tx_size; ++i) {
+				long tag = cborDecoder.readTag();
+				switch((int)tag) {
+				case 6: // id/generator/start/end
+					long len = cborDecoder.readArrayLength();
+					assert(len==4);
+					cborDecoder.readInt();
+					cborDecoder.readInt();
+					cborDecoder.readInt();
+					cborDecoder.readInt();
+					break;
+				default:  { // skip over 7:begin attr, 8:record attr, 9:end attr
+					long sz = cborDecoder.readArrayLength();
+					assert(sz==3);
+					long name_id = cborDecoder.readInt();
+					long type_id = cborDecoder.readInt();
+					String attrName = strDict.get((int)name_id);
+					if(!attributeTypes.containsKey(attrName)) {
+						attributeTypes.put(attrName, new TxAttributeType(attrName, DataType.values()[(int)type_id], AssociationType.values()[(int)tag-7]));
+					} 
+					TxAttributeType attrType = attributeTypes.get(attrName);
+					switch((int)type_id) {
+					case 0: // BOOLEAN
+						ITxAttribute b = new TxAttribute(attrType, cborDecoder.readInt()>0?"True":"False");
+						ret.add(b);
+						break;
+					case 2: // INTEGER
+					case 3: // UNSIGNED
+						ITxAttribute a = new TxAttribute(attrType, String.valueOf(cborDecoder.readInt()));
+						ret.add(a);
+						break;
+					case 4: // FLOATING_POINT_NUMBER
+					case 7: // FIXED_POINT_INTEGER
+					case 8: // UNSIGNED_FIXED_POINT_INTEGER
+						ITxAttribute v = new TxAttribute(attrType, String.valueOf(cborDecoder.readFloat()));
+						ret.add(v);
+						break;
+					case 1: // ENUMERATION
+					case 5: // BIT_VECTOR
+					case 6: // LOGIC_VECTOR
+					case 12: // STRING
+						ITxAttribute s = new TxAttribute(attrType, strDict.get((int)cborDecoder.readInt()));
+						ret.add(s);
+						break;
+					}
+				}
+				}
+			}
+		} catch (IOException e) {
+			LOG.error("Error parsing file "+file.getName(), e);
+		}
+		return ret;
+	}
+
+	/**
+	 * Dispose.
+	 */
+	@Override
+	public void dispose() {
+		attrValues.clear();
+		relationTypes.clear();
+		txStreams.clear();
+		txGenerators.clear();
+		transactions.clear();
+		attributeTypes.clear();
+		relationsIn.clear();
+		relationsOut.clear();
+	}
+
+	/**
+	 * The Class TextDbParser.
+	 */
+	static class CborDbParser extends CborDecoder {
+
+		static final private CborType break_type = CborType.valueOf(0xff);
+
+		/** The loader. */
+		final FtrDbLoader loader;
+
+		/**
+		 * Instantiates a new text db parser.
+		 *
+		 * @param loader the loader
+		 */
+		public CborDbParser(FtrDbLoader loader, FileInputStream inputStream) {
+			super(inputStream);
+			this.loader = loader;
+			try {
+				long cbor_tag = readTag();
+				assert(cbor_tag == 55799);
+				long array_len = readArrayLength();
+				assert(array_len==-1);
+				CborType next = peekType();
+				while(next != null && !break_type.isEqualType(next)) {
+					long tag = readTag();
+					switch((int)tag) {
+					case 6: // info
+						break;
+					case 8: { // dictionary uncompressed
+						parseDict(new CborDecoder(new ByteArrayInputStream(readByteString())));
+						break;
+					}
+					case 10: { // directory uncompressed
+						parseDir(new CborDecoder(new ByteArrayInputStream(readByteString())));
+						break;
+					}
+					case 12: { //tx chunk uncompressed
+						long len = readArrayLength(); 
+						assert(len==2);
+						long stream_id = readInt();
+						TxStream txStream = loader.txStreams.get(stream_id);
+						txStream.fileOffsets.add(inputStream.getChannel().position());
+						parseTx(txStream, txStream.fileOffsets.size()-1, readByteString());
+						break;
+					}
+					case 14: { // relations uncompressed
+						parseRel(new CborDecoder(new ByteArrayInputStream(readByteString())));
+						break;
+					}
+					}
+					next = peekType();
+				}
+			} catch(IOException e) {
+				LOG.error("Error parsing file input stream", e);
+			}
+		}
+
+
+		private void parseDict(CborDecoder cborDecoder) throws IOException {
+			long size = cborDecoder.readMapLength();
+			ArrayList<String> lst = new ArrayList<>((int)size);
+			for(long i = 0; i<size; ++i) {
+				long idx = cborDecoder.readInt();
+				assert(idx==loader.strDict.size()+1);
+				lst.add(cborDecoder.readTextString());
+			}
+			loader.strDict.addAll(lst);
+		}
+
+		private void parseDir(CborDecoder cborDecoder) throws IOException {
+			long size = cborDecoder.readArrayLength();
+			if(size<0) {
+				CborType next = cborDecoder.peekType();
+				while(next != null && !break_type.isEqualType(next)) {
+					parseDictEntry(cborDecoder);
+					next = cborDecoder.peekType();
+				}				
+			} else 
+				for(long i = 0; i<size; ++i) {
+					parseDictEntry(cborDecoder);
+				}
+		}
+
+
+		private void parseDictEntry(CborDecoder cborDecoder) throws IOException {
+			long id = cborDecoder.readTag();
+			if(id==16) { // a stream
+				long len = cborDecoder.readArrayLength();
+				assert(len==3);
+				long stream_id = cborDecoder.readInt();
+				long name_id = cborDecoder.readInt();
+				long kind_id = cborDecoder.readInt();
+				add(stream_id, new TxStream(loader, stream_id, loader.strDict.get((int)name_id), loader.strDict.get((int)kind_id)));
+			} else if(id==17) { // a generator
+				long len = cborDecoder.readArrayLength();
+				assert(len==3);
+				long gen_id = cborDecoder.readInt();
+				long name_id = cborDecoder.readInt();
+				long stream_id = cborDecoder.readInt();
+				add(gen_id, new TxGenerator(loader, gen_id, loader.strDict.get((int)name_id), loader.txStreams.get(stream_id)));
+			} else {
+				throw new IOException("Illegal tage ncountered: "+id);
+			}
+		}
+
+		private void parseTx(TxStream txStream, long blockId, byte[] chunk) throws IOException {
+			CborDecoder cborDecoder = new CborDecoder(new ByteArrayInputStream(chunk));
+			long size = cborDecoder.readArrayLength();
+			assert(size==-1);
+			CborType next = cborDecoder.peekType();
+			while(next != null && !break_type.isEqualType(next)) {
+				long blockOffset = cborDecoder.getPos();
+				long tx_size = cborDecoder.readArrayLength();
+				for(long i = 0; i<tx_size; ++i) {
+					long tag = cborDecoder.readTag();
+					switch((int)tag) {
+					case 6: // id/generator/start/end
+						long len = cborDecoder.readArrayLength();
+						assert(len==4);
+						long txId = cborDecoder.readInt();
+						long genId = cborDecoder.readInt();
+						long startTime = cborDecoder.readInt()*1000; //TODO: scale based on info
+						long endTime = cborDecoder.readInt()*1000; //TODO: scale based on info
+						TxGenerator gen = loader.txGenerators.get(genId);
+						FtrTx scvTx = new FtrTx(txId, gen.stream.getId(), genId, startTime, endTime, blockId, blockOffset);
+						loader.maxTime = loader.maxTime > scvTx.endTime ? loader.maxTime : scvTx.endTime;
+						loader.transactions.put(txId, scvTx);
+						TxStream stream = loader.txStreams.get(gen.stream.getId());
+						if (scvTx.beginTime == scvTx.endTime) {
+							stream.addEvent(new TxEvent(loader, EventKind.SINGLE, txId, scvTx.beginTime));
+							gen.addEvent(new TxEvent(loader, EventKind.SINGLE, txId, scvTx.beginTime));
+						} else {
+							stream.addEvent(new TxEvent(loader, EventKind.BEGIN, txId, scvTx.beginTime));
+							gen.addEvent(new TxEvent(loader, EventKind.BEGIN, txId, scvTx.beginTime));
+							stream.addEvent(new TxEvent(loader, EventKind.END, txId, scvTx.endTime));
+							gen.addEvent(new TxEvent(loader, EventKind.END, txId, scvTx.endTime));
+						}
+						break;
+					default:  { // skip over 7:begin attr, 8:record attr, 9:end attr
+						long sz = cborDecoder.readArrayLength();
+						assert(sz==3);
+						for(long j = 0; j<sz; ++j)
+							cborDecoder.readInt();
+					}
+					}
+				}
+				next = cborDecoder.peekType();
+			}							
+		}
+
+		private void parseRel(CborDecoder cborDecoder) throws IOException {
+			long size = cborDecoder.readArrayLength();
+			assert(size==-1);
+			CborType next = cborDecoder.peekType();
+			while(next != null && !break_type.isEqualType(next)) {
+				long sz = cborDecoder.readArrayLength();
+				assert(sz==3);
+				long type_id = cborDecoder.readInt();
+				long from_id = cborDecoder.readInt();
+				long to_id = cborDecoder.readInt();
+				String rel_name = loader.strDict.get((int)type_id);
+				FtrRelation ftrRel = new FtrRelation(loader.relationTypes.getOrDefault(rel_name, RelationTypeFactory.create(rel_name)), from_id, to_id);
+				loader.relationsOut.put(from_id, ftrRel);
+				loader.relationsIn.put(to_id, ftrRel);
+				next = cborDecoder.peekType();
+			}							
+			
+		}
+		
+		private void add(Long id, TxStream stream) {
+			loader.txStreams.put(id, stream);
+			loader.pcs.firePropertyChange(IWaveformDbLoader.STREAM_ADDED, null, stream);
+		}
+
+		private void add(Long id, TxGenerator generator) {
+			loader.txGenerators.put(id, generator);
+			loader.pcs.firePropertyChange(IWaveformDbLoader.GENERATOR_ADDED, null, generator);
+		}
+	}
+
+}

plugins/com.minres.scviewer.database.ftr/src/com/minres/scviewer/database/ftr/FtrDbLoaderFactory.java

@@ -0,0 +1,68 @@
+/*******************************************************************************
+ * Copyright (c) 2012 IT Just working.
+ * Copyright (c) 2020 MINRES Technologies GmbH
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ *     IT Just working - initial API and implementation
+ *******************************************************************************/
+package com.minres.scviewer.database.ftr;
+
+import java.io.BufferedInputStream;
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.zip.GZIPInputStream;
+
+import org.apache.commons.compress.compressors.lz4.FramedLZ4CompressorInputStream;
+
+import com.minres.scviewer.database.IWaveformDbLoader;
+import com.minres.scviewer.database.IWaveformDbLoaderFactory;
+import com.minres.scviewer.database.ftr.FtrDbLoader.FileType;
+
+/**
+ * The Class TextDbLoader.
+ */
+public class FtrDbLoaderFactory implements IWaveformDbLoaderFactory {
+
+	public static byte[] hexStringToByteArray(String s) {
+	    int len = s.length();
+	    byte[] data = new byte[len / 2];
+	    for (int i = 0; i < len; i += 2) {
+	        data[i / 2] = (byte) ((Character.digit(s.charAt(i), 16) << 4)
+	                             + Character.digit(s.charAt(i+1), 16));
+	    }
+	    return data;
+	}
+	/** The Constant x. */
+	static final byte[] x =  hexStringToByteArray("d9d9f79f");
+
+	/**
+	 * Can load.
+	 *
+	 * @param inputFile the input file
+	 * @return true, if successful
+	 */
+	@Override
+	public boolean canLoad(File inputFile) {
+		try (InputStream is = new FileInputStream(inputFile)) {
+			byte[] buffer = new byte[x.length];
+			int readCnt = is.read(buffer, 0, x.length);
+			if (readCnt == x.length) {
+				for (int i = 0; i < x.length; i++)
+					if (buffer[i] != x[i]) return false;
+			}
+			return true;
+		} catch (IOException e) {}
+		return false;
+	}
+
+	@Override
+	public IWaveformDbLoader getLoader() {
+		return new FtrDbLoader();
+	}
+}

plugins/com.minres.scviewer.database.ftr/src/com/minres/scviewer/database/ftr/FtrRelation.java

@@ -0,0 +1,47 @@
+/*******************************************************************************
+ * Copyright (c) 2020 MINRES Technologies GmbH and others.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ *     MINRES Technologies GmbH - initial API and implementation
+ *******************************************************************************/
+package com.minres.scviewer.database.ftr;
+
+import java.io.Serializable;
+
+import com.minres.scviewer.database.RelationType;
+
+/**
+ * The Class ScvRelation.
+ */
+class FtrRelation implements Serializable {
+
+	/** The Constant serialVersionUID. */
+	private static final long serialVersionUID = -347668857680574140L;
+
+	/** The source. */
+	final long source;
+
+	/** The target. */
+	final long target;
+
+	/** The relation type. */
+	final RelationType relationType;
+
+	/**
+	 * Instantiates a new scv relation.
+	 *
+	 * @param relationType the relation type
+	 * @param source       the source
+	 * @param target       the target
+	 */
+	public FtrRelation(RelationType relationType, long source, long target) {
+		this.source = source;
+		this.target = target;
+		this.relationType = relationType;
+	}
+
+}

plugins/com.minres.scviewer.database.ftr/src/com/minres/scviewer/database/ftr/FtrTx.java

@@ -0,0 +1,93 @@
+/*******************************************************************************
+ * Copyright (c) 2012 IT Just working.
+ * Copyright (c) 2020 MINRES Technologies GmbH
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ *     IT Just working - initial API and implementation
+ *******************************************************************************/
+package com.minres.scviewer.database.ftr;
+
+import java.io.ByteArrayInputStream;
+import java.io.Serializable;
+import java.util.ArrayList;
+import java.util.List;
+
+import com.minres.scviewer.database.InputFormatException;
+import com.minres.scviewer.database.tx.ITxAttribute;
+
+import jacob.CborDecoder;
+
+/**
+ * The Class ScvTx.
+ */
+class FtrTx implements Serializable {
+
+	/** The Constant serialVersionUID. */
+	private static final long serialVersionUID = -855200240003328221L;
+
+	/** The id. */
+	final long id;
+
+	/** The generator id. */
+	final long generatorId;
+
+	/** The stream id. */
+	final long streamId;
+
+	/** The begin time. */
+	long beginTime;
+
+	/** The end time. */
+	long endTime;
+
+	/** The attributes. */
+	final List<ITxAttribute> attributes = new ArrayList<>();
+
+	final long blockId;
+
+	final long blockOffset;
+
+	/**
+	 * Instantiates a new scv tx.
+	 *
+	 * @param id          the id
+	 * @param streamId    the stream id
+	 * @param generatorId the generator id
+	 * @param begin       the begin
+	 */
+	FtrTx(long id, long streamId, long generatorId, long begin, long end, long blockId, long blockOffset) {
+		this.id = id;
+		this.streamId = streamId;
+		this.generatorId = generatorId;
+		this.beginTime = begin;
+		this.endTime = end;
+		this.blockId=blockId;
+		this.blockOffset=blockOffset;
+	}
+
+	/**
+	 * Gets the id.
+	 *
+	 * @return the id
+	 */
+	Long getId() {
+		return id;
+	}
+
+	public List<ITxAttribute> getAttributes(FtrDbLoader loader) {
+		if(attributes.size()==0)
+			try {
+				TxStream stream = loader.txStreams.get(streamId);
+				byte[] chunk = stream.getChunks().get((int)blockId);
+				attributes.addAll(loader.parseAtrributes(chunk, blockOffset));
+			} catch (InputFormatException e) {
+				// TODO Auto-generated catch block
+				e.printStackTrace();
+			}
+		return attributes;
+	}
+}

plugins/com.minres.scviewer.database.ftr/src/com/minres/scviewer/database/ftr/Tx.java

@@ -0,0 +1,233 @@
+/*******************************************************************************
+ * Copyright (c) 2012 IT Just working.
+ * Copyright (c) 2020 MINRES Technologies GmbH
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ *     IT Just working - initial API and implementation
+ *******************************************************************************/
+package com.minres.scviewer.database.ftr;
+
+import java.util.Collection;
+import java.util.List;
+import java.util.Set;
+import java.util.stream.Collectors;
+
+import com.minres.scviewer.database.IWaveform;
+import com.minres.scviewer.database.InputFormatException;
+import com.minres.scviewer.database.tx.ITx;
+import com.minres.scviewer.database.tx.ITxAttribute;
+import com.minres.scviewer.database.tx.ITxRelation;
+
+/**
+ * The Class Tx.
+ */
+class Tx implements ITx {
+
+	/** The loader. */
+	private final FtrDbLoader loader;
+	
+	private FtrTx scvTx =null;
+
+	/** The id. */
+	private final long id;
+
+	private final long generatorId;
+
+	private final long streamId;
+
+	/** The begin time. */
+	long beginTime = -1;
+
+	/** The end time. */
+	long endTime = -1;
+
+	/**
+	 * Instantiates a new tx.
+	 *
+	 * @param loader the loader
+	 * @param scvTx  the scv tx
+	 */
+	public Tx(FtrDbLoader loader, FtrTx scvTx) {
+		this.loader = loader;
+		id = scvTx.id;
+		this.scvTx=scvTx;
+		generatorId=scvTx.generatorId;
+		streamId=scvTx.streamId;
+		beginTime=scvTx.beginTime;
+		endTime=scvTx.endTime;
+	}
+
+	/**
+	 * Instantiates a new tx.
+	 *
+	 * @param loader the loader
+	 * @param txId   the tx id
+	 */
+	public Tx(FtrDbLoader loader, long id, long generatorId,  long streamId) {
+		this.loader = loader;
+		this.id = id;
+		this.generatorId=generatorId;
+		this.streamId = streamId;
+	}
+
+	/**
+	 * Gets the incoming relations.
+	 *
+	 * @return the incoming relations
+	 */
+	@Override
+	public Collection<ITxRelation> getIncomingRelations() {
+		Set<FtrRelation> rels = loader.relationsIn.get(id);
+		return rels.stream().map(rel -> new TxRelation(loader, rel)).collect(Collectors.toList());
+	}
+
+	/**
+	 * Gets the outgoing relations.
+	 *
+	 * @return the outgoing relations
+	 */
+	@Override
+	public Collection<ITxRelation> getOutgoingRelations() {
+		Set<FtrRelation> rels = loader.relationsOut.get(id);
+		return rels.stream().map(rel -> new TxRelation(loader, rel)).collect(Collectors.toList());
+	}
+
+	/**
+	 * Compare to.
+	 *
+	 * @param o the o
+	 * @return the int
+	 */
+	@Override
+	public int compareTo(ITx o) {
+		int res = Long.compare(getBeginTime(), o.getBeginTime());
+		if (res != 0)
+			return res;
+		else
+			return Long.compare(getId(), o.getId());
+	}
+
+	/**
+	 * Equals.
+	 *
+	 * @param obj the obj
+	 * @return true, if successful
+	 */
+	@Override
+	public boolean equals(Object obj) {
+		if (this == obj)
+			return true;
+		if (obj == null || getClass() != obj.getClass())
+			return false;
+		return this.getScvTx().equals(((Tx) obj).getScvTx());
+	}
+
+	/**
+	 * Hash code.
+	 *
+	 * @return the int
+	 */
+	@Override
+	public int hashCode() {
+		return getScvTx().hashCode();
+	}
+
+	/**
+	 * To string.
+	 *
+	 * @return the string
+	 */
+	@Override
+	public String toString() {
+		return "tx#" + getId() + "[" + getBeginTime() / 1000000 + "ns - " + getEndTime() / 1000000 + "ns]";
+	}
+
+	/**
+	 * Gets the id.
+	 *
+	 * @return the id
+	 */
+	@Override
+	public long getId() {
+		return getScvTx().id;
+	}
+
+	/**
+	 * Gets the stream.
+	 *
+	 * @return the stream
+	 */
+	@Override
+	public IWaveform getStream() {
+		return loader.txStreams.get(streamId);
+	}
+
+	/**
+	 * Gets the generator.
+	 *
+	 * @return the generator
+	 */
+	@Override
+	public IWaveform getGenerator() {
+		return loader.txGenerators.get(generatorId);
+	}
+
+	/**
+	 * Gets the begin time.
+	 *
+	 * @return the begin time
+	 */
+	@Override
+	public long getBeginTime() {
+		if (beginTime < 0) {
+			FtrTx tx = scvTx==null?loader.getScvTx(id):getScvTx();
+			beginTime = tx.beginTime;
+			endTime = tx.endTime;
+		}
+		return beginTime;
+	}
+
+	/**
+	 * Gets the end time.
+	 *
+	 * @return the end time
+	 */
+	@Override
+	public long getEndTime() {
+		if (endTime < 0) {
+			FtrTx tx = scvTx==null?loader.getScvTx(id):getScvTx();
+			beginTime = tx.beginTime;
+			endTime = tx.endTime;
+		}
+		return endTime;
+	}
+
+	/**
+	 * Sets the end time.
+	 *
+	 * @param time the new end time
+	 */
+	void setEndTime(Long time) {
+		getScvTx().endTime = time;
+	}
+
+	/**
+	 * Gets the attributes.
+	 *
+	 * @return the attributes
+	 */
+	@Override
+	public List<ITxAttribute> getAttributes() {
+		return getScvTx().getAttributes(loader);
+	}
+
+	private FtrTx getScvTx() {
+		if(scvTx==null)
+			scvTx=loader.getScvTx(id);
+		return scvTx;
+	}
+}

plugins/com.minres.scviewer.database.ftr/src/com/minres/scviewer/database/ftr/TxAttribute.java

@@ -0,0 +1,85 @@
+/*******************************************************************************
+ * Copyright (c) 2012 IT Just working.
+ * Copyright (c) 2020 MINRES Technologies GmbH
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ *     IT Just working - initial API and implementation
+ *******************************************************************************/
+package com.minres.scviewer.database.ftr;
+
+import java.io.Serializable;
+
+import com.minres.scviewer.database.AssociationType;
+import com.minres.scviewer.database.DataType;
+import com.minres.scviewer.database.tx.ITxAttribute;
+
+/**
+ * The Class TxAttribute.
+ */
+public class TxAttribute implements ITxAttribute, Serializable {
+
+	/** The Constant serialVersionUID. */
+	private static final long serialVersionUID = 4767726016651807152L;
+
+	/** The attribute type. */
+	private final TxAttributeType attributeType;
+
+	/** The value. */
+	private final String value;
+
+	/**
+	 * Instantiates a new tx attribute.
+	 *
+	 * @param type  the type
+	 * @param value the value
+	 */
+	TxAttribute(TxAttributeType type, String value) {
+		this.attributeType = type;
+		this.value = value;
+	}
+
+	/**
+	 * Gets the name.
+	 *
+	 * @return the name
+	 */
+	@Override
+	public String getName() {
+		return attributeType.getName();
+	}
+
+	/**
+	 * Gets the type.
+	 *
+	 * @return the type
+	 */
+	@Override
+	public AssociationType getType() {
+		return attributeType.getType();
+	}
+
+	/**
+	 * Gets the data type.
+	 *
+	 * @return the data type
+	 */
+	@Override
+	public DataType getDataType() {
+		return attributeType.getDataType();
+	}
+
+	/**
+	 * Gets the value.
+	 *
+	 * @return the value
+	 */
+	@Override
+	public Object getValue() {
+		return value;
+	}
+
+}

plugins/com.minres.scviewer.database.ftr/src/com/minres/scviewer/database/ftr/TxAttributeType.java

@@ -0,0 +1,84 @@
+/*******************************************************************************
+ * Copyright (c) 2012 IT Just working.
+ * Copyright (c) 2020 MINRES Technologies GmbH
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ *     IT Just working - initial API and implementation
+ *******************************************************************************/
+package com.minres.scviewer.database.ftr;
+
+import java.io.Serializable;
+
+import com.minres.scviewer.database.AssociationType;
+import com.minres.scviewer.database.DataType;
+import com.minres.scviewer.database.tx.ITxAttributeType;
+
+/**
+ * The Class TxAttributeType.
+ */
+class TxAttributeType implements ITxAttributeType, Serializable {
+
+	/** The Constant serialVersionUID. */
+	private static final long serialVersionUID = 7159721937208946828L;
+
+	/** The name. */
+	private String name;
+
+	/** The data type. */
+	private DataType dataType;
+
+	/** The type. */
+	private AssociationType type;
+
+	/**
+	 * Instantiates a new tx attribute type.
+	 *
+	 * @param name     the name
+	 * @param dataType the data type
+	 * @param type     the type
+	 */
+	TxAttributeType(String name, DataType dataType, AssociationType type) {
+		this.name = name;
+		this.dataType = dataType;
+		this.type = type;
+	}
+
+	/**
+	 * Gets the name.
+	 *
+	 * @return the name
+	 */
+	@Override
+	public String getName() {
+		return name;
+	}
+
+	/**
+	 * Gets the data type.
+	 *
+	 * @return the data type
+	 */
+	@Override
+	public DataType getDataType() {
+		return dataType;
+	}
+
+	/**
+	 * Gets the type.
+	 *
+	 * @return the type
+	 */
+	@Override
+	public AssociationType getType() {
+		return type;
+	}
+	
+	@Override
+	public String toString() {
+		return name + ":" + dataType.name() + "@" + type.name();
+	}
+}

plugins/com.minres.scviewer.database.ftr/src/com/minres/scviewer/database/ftr/TxEvent.java

@@ -0,0 +1,120 @@
+/*******************************************************************************
+ * Copyright (c) 2020 MINRES Technologies GmbH and others.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ *     MINRES Technologies GmbH - initial API and implementation
+ *******************************************************************************/
+package com.minres.scviewer.database.ftr;
+
+import com.minres.scviewer.database.EventKind;
+import com.minres.scviewer.database.WaveformType;
+import com.minres.scviewer.database.tx.ITx;
+import com.minres.scviewer.database.tx.ITxEvent;
+
+/**
+ * The Class TxEvent.
+ */
+class TxEvent implements ITxEvent {
+
+	/** The loader. */
+	final FtrDbLoader loader;
+
+	/** The kind. */
+	final EventKind kind;
+
+	/** The transaction. */
+	final long transaction;
+
+	/** The time. */
+	final long time;
+
+	private int concurrencyIdx=-1;
+	/**
+	 * Instantiates a new tx event.
+	 *
+	 * @param loader      the loader
+	 * @param kind        the kind
+	 * @param transaction the transaction
+	 * @param time        the time
+	 */
+	TxEvent(FtrDbLoader loader, EventKind kind, Long transaction, Long time) {
+		this.loader = loader;
+		this.kind = kind;
+		this.transaction = transaction;
+		this.time = time;
+	}
+
+	/**
+	 * Duplicate.
+	 *
+	 * @return the i tx event
+	 * @throws CloneNotSupportedException the clone not supported exception
+	 */
+	@Override
+	public ITxEvent duplicate() throws CloneNotSupportedException {
+		return new TxEvent(loader, kind, transaction, time);
+	}
+
+	/**
+	 * To string.
+	 *
+	 * @return the string
+	 */
+	@Override
+	public String toString() {
+		return kind.toString() + "@" + time + " of tx #" + transaction;
+	}
+
+	/**
+	 * Gets the type.
+	 *
+	 * @return the type
+	 */
+	@Override
+	public WaveformType getType() {
+		return WaveformType.TRANSACTION;
+	}
+
+	/**
+	 * Gets the kind.
+	 *
+	 * @return the kind
+	 */
+	@Override
+	public EventKind getKind() {
+		return kind;
+	}
+
+	/**
+	 * Gets the time.
+	 *
+	 * @return the time
+	 */
+	@Override
+	public long getTime() {
+		return time;
+	}
+
+	/**
+	 * Gets the transaction.
+	 *
+	 * @return the transaction
+	 */
+	@Override
+	public ITx getTransaction() {
+		return loader.getTransaction(transaction);
+	}
+
+	@Override
+	public int getRowIndex() {
+		return concurrencyIdx;
+	}
+
+	public void setConcurrencyIndex(int idx) {
+		concurrencyIdx=idx;
+	}
+}

plugins/com.minres.scviewer.database.ftr/src/com/minres/scviewer/database/ftr/TxGenerator.java

@@ -0,0 +1,96 @@
+/*******************************************************************************
+ * Copyright (c) 2012 IT Just working.
+ * Copyright (c) 2020 MINRES Technologies GmbH
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ *     IT Just working - initial API and implementation
+ *******************************************************************************/
+package com.minres.scviewer.database.ftr;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import com.minres.scviewer.database.IWaveform;
+
+/**
+ * The Class TxGenerator.
+ */
+class TxGenerator extends AbstractTxStream {
+
+	/** The stream. */
+	TxStream stream;
+
+	/** The begin attrs. */
+	List<TxAttributeType> beginAttrs = new ArrayList<>();
+
+	/** The end attrs. */
+	List<TxAttributeType> endAttrs = new ArrayList<>();
+
+	/**
+	 * Instantiates a new tx generator.
+	 *
+	 * @param loader the loader
+	 * @param id     the id
+	 * @param name   the name
+	 * @param stream the stream
+	 */
+	TxGenerator(FtrDbLoader loader, Long id, String name, TxStream stream) {
+		super(loader, id, name);
+		this.stream = stream;
+		stream.addChild(this);
+	}
+
+	/**
+	 * Checks if is same.
+	 *
+	 * @param other the other
+	 * @return true, if is same
+	 */
+	@Override
+	public boolean isSame(IWaveform other) {
+		return (other instanceof TxGenerator && this.getId()==other.getId());
+	}
+
+	/**
+	 * Gets the begin attrs.
+	 *
+	 * @return the begin attrs
+	 */
+	public List<TxAttributeType> getBeginAttrs() {
+		return beginAttrs;
+	}
+
+	/**
+	 * Gets the end attrs.
+	 *
+	 * @return the end attrs
+	 */
+	public List<TxAttributeType> getEndAttrs() {
+		return endAttrs;
+	}
+
+	/**
+	 * Gets the kind.
+	 *
+	 * @return the kind
+	 */
+	@Override
+	public String getKind() {
+		return stream.getKind();
+	}
+	
+	/**
+	 * Gets the full hierarchical name.
+	 *
+	 * @return the full name
+	 */
+	@Override
+	public String getFullName() {
+		return  ((AbstractTxStream)parent).getFullName()+"."+name;
+	}
+
+}

plugins/com.minres.scviewer.database.ftr/src/com/minres/scviewer/database/ftr/TxRelation.java

@@ -0,0 +1,69 @@
+/*******************************************************************************
+ * Copyright (c) 2020 MINRES Technologies GmbH and others.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ *     MINRES Technologies GmbH - initial API and implementation
+ *******************************************************************************/
+package com.minres.scviewer.database.ftr;
+
+import com.minres.scviewer.database.RelationType;
+import com.minres.scviewer.database.tx.ITx;
+import com.minres.scviewer.database.tx.ITxRelation;
+
+/**
+ * The Class TxRelation.
+ */
+class TxRelation implements ITxRelation {
+
+	/** The loader. */
+	final FtrDbLoader loader;
+
+	/** The scv relation. */
+	final FtrRelation scvRelation;
+
+	/**
+	 * Instantiates a new tx relation.
+	 *
+	 * @param loader      the loader
+	 * @param scvRelation the scv relation
+	 */
+	public TxRelation(FtrDbLoader loader, FtrRelation scvRelation) {
+		this.loader = loader;
+		this.scvRelation = scvRelation;
+	}
+
+	/**
+	 * Gets the relation type.
+	 *
+	 * @return the relation type
+	 */
+	@Override
+	public RelationType getRelationType() {
+		return scvRelation.relationType;
+	}
+
+	/**
+	 * Gets the source.
+	 *
+	 * @return the source
+	 */
+	@Override
+	public ITx getSource() {
+		return loader.getTransaction(scvRelation.source);
+	}
+
+	/**
+	 * Gets the target.
+	 *
+	 * @return the target
+	 */
+	@Override
+	public ITx getTarget() {
+		return loader.getTransaction(scvRelation.target);
+	}
+
+}

plugins/com.minres.scviewer.database.ftr/src/com/minres/scviewer/database/ftr/TxStream.java

@@ -0,0 +1,73 @@
+/*******************************************************************************
+ * Copyright (c) 2012 IT Just working.
+ * Copyright (c) 2020 MINRES Technologies GmbH
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ *     IT Just working - initial API and implementation
+ *******************************************************************************/
+package com.minres.scviewer.database.ftr;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import com.minres.scviewer.database.IWaveform;
+import com.minres.scviewer.database.InputFormatException;
+
+/**
+ * The Class TxStream.
+ */
+class TxStream extends AbstractTxStream {
+
+	/** The kind. */
+	final String kind;
+
+	final ArrayList<Long> fileOffsets = new ArrayList<>();
+	
+	final ArrayList<byte[]> chunks = new ArrayList<>();
+
+	/**
+	 * Instantiates a new tx stream.
+	 *
+	 * @param loader the loader
+	 * @param id     the id
+	 * @param name   the name
+	 * @param kind   the kind
+	 */
+	TxStream(FtrDbLoader loader, Long id, String name, String kind) {
+		super(loader, id, name);
+		this.kind = kind;
+	}
+
+	/**
+	 * Checks if is same.
+	 *
+	 * @param other the other
+	 * @return true, if is same
+	 */
+	@Override
+	public boolean isSame(IWaveform other) {
+		return (other instanceof TxStream && this.getId() == other.getId());
+	}
+
+	/**
+	 * Gets the kind.
+	 *
+	 * @return the kind
+	 */
+	@Override
+	public String getKind() {
+		return kind;
+	}
+
+	public List<byte[]> getChunks() throws InputFormatException {
+		if(chunks.size()==0) {
+			chunks.addAll(loader.getChunksAtOffsets(fileOffsets));
+		}
+		return chunks;
+	}
+
+}