From: luukkainen <luukkainen@ac1ea38d-2e2b-0410-8846-a27921b304fc>
Date: Tue, 7 Aug 2012 11:29:52 +0000 (+0000)
Subject: Ability to make skipped & partial reads for multiple items at the same time.
X-Git-Tag: simantics-1.7~6
X-Git-Url: https://gerrit.simantics.org/r/gitweb?a=commitdiff_plain;h=29a8658cabc21f95986e096b6d8e9531260f3406;p=simantics%2Fsysdyn.git

Ability to make skipped & partial reads for multiple items at the same time.

refs #3544

git-svn-id: https://www.simantics.org/svn/simantics/sysdyn/trunk@25395 ac1ea38d-2e2b-0410-8846-a27921b304fc
---

diff --git a/org.simantics.modelica/src/org/simantics/modelica/reader/MatFileReader.java b/org.simantics.modelica/src/org/simantics/modelica/reader/MatFileReader.java
index 9571ee34..49170171 100644
--- a/org.simantics.modelica/src/org/simantics/modelica/reader/MatFileReader.java
+++ b/org.simantics.modelica/src/org/simantics/modelica/reader/MatFileReader.java
@@ -110,6 +110,31 @@ public class MatFileReader implements ResultFileReader {
 
 	}
 	
+	@Override
+	public double[][] readData(List<String> items, int start, int count,
+			int skip) throws IOException {
+		readBytes = 0;
+		
+		List<Integer> indexes = new ArrayList<Integer>(items.size());
+		for (String item : items) {
+			Integer index = indices.get(item);
+			if (index == null)
+				throw new IOException("Unknown item: " + item);
+			indexes.add(index);
+		}
+		
+		InputStream in = new FileInputStream(file);
+		skip(dataMark, in);
+		
+		
+		
+		Object data = readRows(dataHeader, indexes,start,count,skip, in);
+		
+		in.close();
+		
+		return (double[][])data;
+	}
+	
 	
 	private void readVariables() throws IOException {
 		InputStream in = new FileInputStream(file);
@@ -415,6 +440,112 @@ public class MatFileReader implements ResultFileReader {
     	return vs;
     }
     
+	
+	private double[][] readRows(MatrixHeader header, List<Integer> unSortedRows, int start, int count, int skip, InputStream in)throws IOException {
+
+		
+		;
+		
+		if (header.type != 0)
+    		throw new IOException("Only double type supported");
+		for (int row : unSortedRows)
+			if (infoData[row * 4] != 2)
+				throw new IOException();  // this is checked in initialization phase.
+		
+		
+		
+		int size = header.columns;
+		int rows = header.rows;
+		
+		if (start+count*(skip+1) > size)
+			throw new IndexOutOfBoundsException(); // TODO: we could just read available data, instead of throwing exception.
+		
+		int usc[] = new int[unSortedRows.size()];
+		int uc[] = new int[unSortedRows.size()];
+		double vs[][] = new double[unSortedRows.size()][];
+		for (int i = 0; i < unSortedRows.size(); i++) {
+			int row = unSortedRows.get(i);
+			vs[i] = new double[count];
+			usc[i] = infoData[row * 4 + 1];
+			uc[i] = usc[i] > 0 ? usc[i]-1 : 1-usc[i];
+		}
+		
+		Map<Integer, Integer> cToRow = new HashMap<Integer, Integer>();
+		List<Integer> sortedCs = new ArrayList<Integer>();
+		for (int i = 0; i < unSortedRows.size(); i++) {
+			cToRow.put(uc[i], unSortedRows.get(i));
+			sortedCs.add(uc[i]);
+		}
+		
+		List<Integer> sortedRows = new ArrayList<Integer>();
+		int sc[] = new int[unSortedRows.size()];
+		int c[] = new int[unSortedRows.size()];
+		
+		Collections.sort(sortedCs);
+		for (int i = 0; i < unSortedRows.size(); i++) {
+			int row = cToRow.get(sortedCs.get(i));
+			sortedRows.add(row);
+			sc[i] = usc[unSortedRows.indexOf(row)];
+			c[i] = uc[unSortedRows.indexOf(row)];
+		}
+	
+		
+		
+//		skip((c+start*rows) * 8, in);
+//    	for (int j = 0; j < v.length; ++j) {
+//    		
+//    		double d = getDouble(in);
+//    		v[j] = d;
+//    		skip((rows*skip + rows-1)*8,in);
+//		}
+//
+//    	
+//    	 if(sc < 0)
+//             for(int j=0;j<v.length;++j)
+//                 v[j] = -v[j];
+//         return v;
+		
+		skip((start*rows) * 8, in);
+    	skip(c[0] * 8, in);
+    	for (int j = 0; j < count; ++j) {
+    		for (int index = 0; index < sortedRows.size(); index++) {
+    				
+    				double d = getDouble(in);
+    				vs[index][j] = d;
+    			
+    				if (index < sortedRows.size() - 1) {
+    					skip((c[index+1] - c[index] -1 )*8, in);
+    				} else {
+    					skip((rows - c[index]-1 + c[0])*8,in);
+    				}
+    				//skip((rows-1)*8,in);
+    		}
+    		if (skip > 0)
+    			skip((skip*rows)*8,in);
+		}
+
+    	
+    	for (int i = 0; i < sortedRows.size(); i++) {
+    		if(sc[i] < 0)
+             for(int j=0;j<vs[i].length;++j)
+                 vs[i][j] = -vs[i][j];
+         
+    	}
+    	for (int i = 0; i < sortedRows.size(); i++) {
+    		int row = sortedRows.get(i);
+    		int rRow = unSortedRows.get(i);
+    		if (row != rRow) {
+    			int ri = sortedRows.indexOf(rRow);
+    			double v[] = vs[i];
+    			vs[i] = vs[ri];
+    			vs[ri] = v;
+    			sortedRows.set(i, rRow);
+    			sortedRows.set(ri, row);
+    		}
+    	}
+    	
+    	return vs;
+    }
     private void skip(int skipBytes, InputStream in) throws IOException {
     	int skip = 0; 
     	while (skip < skipBytes) {
diff --git a/org.simantics.modelica/src/org/simantics/modelica/reader/ResultFileReader.java b/org.simantics.modelica/src/org/simantics/modelica/reader/ResultFileReader.java
index 9292f486..2369d49b 100644
--- a/org.simantics.modelica/src/org/simantics/modelica/reader/ResultFileReader.java
+++ b/org.simantics.modelica/src/org/simantics/modelica/reader/ResultFileReader.java
@@ -45,5 +45,7 @@ public interface ResultFileReader {
 	 * @throws IOException
 	 */
 	public double[][] readData(List<String> items) throws IOException ;
+	
+	public double[][] readData(List<String> items, int start, int count, int skip) throws IOException ;
 
 }