Application: gvSIG desktop » gvSIG raster

package org.gvsig.raster.cache.buffer.impl.rocache;

import java.io.IOException;

import junit.framework.TestCase;

import org.gvsig.jgdal.GdalException;

import org.gvsig.raster.cache.buffer.Buffer;

import org.gvsig.raster.cache.buffer.BufferDataSource;

import org.gvsig.raster.cache.buffer.exception.OperationNotSupportedException;

import org.gvsig.raster.cache.buffer.exception.ProcessInterruptedException;

import org.gvsig.raster.cache.buffer.impl.BufferCacheManagerImpl;

import org.gvsig.raster.cache.buffer.impl.io.BufferDataSourceImpl;

import org.gvsig.raster.cache.buffer.impl.io.GdalRead;

import org.gvsig.raster.cache.buffer.impl.memory.RasterMemoryBuffer;

/**

 * Read a number from cache

 * @author Nacho Brodin (nachobrodin@gmail.com)

 */

public class TestReadTiffAndCompareData extends TestCase {

        private String in = "./src/test/resources/image/001m09_1_0.tif";

        public void start() {

                this.setUp();

                this.testStack();

        }

        public void setUp() {

                System.err.println("ROCache TestReadTiffAndCompareData running...");

        }

        public void testStack() {

                long t1 = System.currentTimeMillis();

                GdalRead input = null;

                BufferCacheManagerImpl.cacheSize = 1;

                BufferCacheManagerImpl.pageSize = 0.2;

                Buffer buf1 = null;

                try {

                        input = new GdalRead(in);

                        Object dataIn = input.readBlock(0, 0, input.getWidth(), input.getHeight());

                        //Create Buffer

                        buf1 = new RasterMemoryBuffer(input.getRasterBufTypeFromGdalType(input.getDataType()), 

                                                                                        input.getWidth(), 

                                                                                        input.getHeight(),

                                                                                        input.getBandCount(),

                                                                                        true);

                        //Set data to buffer

                        setLines(dataIn, buf1);

                } catch (GdalException e1) {

                        e1.printStackTrace();

                } catch (IOException e1) {

                        e1.printStackTrace();

                } catch (ProcessInterruptedException e1) {

                        e1.printStackTrace();

                } catch (OperationNotSupportedException e1) {

                        e1.printStackTrace();

                }

                BufferDataSource ds = null;

                try {

                        ds = new BufferDataSourceImpl(in);

                } catch (IOException e) {

                        e.printStackTrace();

                }

                RasterReadOnlyBuffer buf = new RasterReadOnlyBuffer(ds);

                for (int iBand = 0; iBand < buf.getBandCount(); iBand++) {

                        for (int row = 0; row < buf.getHeight(); row++) {

                                for (int col = 0; col < buf.getWidth(); col++) {

                                        byte n = buf.getElemByte(row, col, iBand);

                                        byte m = buf1.getElemByte(row, col, iBand);

                                        if(n != m)

                                                System.out.println(row + " " + col);

                                        assertEquals(n, m);

                                }

                        }

                }

                try {

                        buf.free();

                } catch (IOException e) {

                        // TODO Auto-generated catch block

                        e.printStackTrace();

                }

                long t2 = System.currentTimeMillis();

                System.out.println("Tiempo ROCache TestRWOneValue: " + (t2 - t1) + " milisegundos");

        }

        private void setLines(Object dataIn, Buffer buf) throws OperationNotSupportedException {

                if(dataIn instanceof byte[][][]) {

                    byte[][][] d = (byte[][][])dataIn;

                    for (int iBand = 0; iBand < d.length; iBand++) {

                                for (int row = 0; row < d[iBand].length; row++) {

                                        buf.setLineInBandByte(d[iBand][row], row, iBand);

                                }

                        }

            }

        }

}