Application: gvSIG desktop » gvSIG raster

/* gvSIG. Geographic Information System of the Valencian Government

 *

 * Copyright (C) 2007-2008 Infrastructures and Transports Department

 * of the Valencian Government (CIT)

 *

 * This program is free software; you can redistribute it and/or

 * modify it under the terms of the GNU General Public License

 * as published by the Free Software Foundation; either version 2

 * of the License, or (at your option) any later version.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,

 * MA  02110-1301, USA.

 *

 */

package org.gvsig.raster.gdal.io;

import java.awt.geom.AffineTransform;

import java.awt.geom.Point2D;

import java.io.File;

import java.io.IOException;

import java.sql.Savepoint;

import java.util.ArrayList;

import org.apache.commons.io.FileUtils;

import org.apache.commons.io.FilenameUtils;

import org.cresques.cts.ICRSFactory;

import org.cresques.cts.IProjection;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.gvsig.fmap.dal.coverage.RasterLibrary;

import org.gvsig.fmap.dal.coverage.RasterLocator;

import org.gvsig.fmap.dal.coverage.dataset.Buffer;

import org.gvsig.fmap.dal.coverage.datastruct.Params;

import org.gvsig.fmap.dal.coverage.exception.NotSupportedExtensionException;

import org.gvsig.fmap.dal.coverage.exception.ProcessInterruptedException;

import org.gvsig.fmap.dal.coverage.exception.RmfSerializerException;

import org.gvsig.fmap.dal.coverage.store.DataServerWriter;

import org.gvsig.jgdal.GdalBuffer;

import org.gvsig.jgdal.GdalDataset;

import org.gvsig.jgdal.GdalDriver;

import org.gvsig.jgdal.GdalException;

import org.gvsig.jgdal.GdalRasterBand;

import org.gvsig.jgdal.GeoTransform;

import org.gvsig.raster.gdal.io.features.BMPFeatures;

import org.gvsig.raster.gdal.io.features.GTiffFeatures;

import org.gvsig.raster.gdal.io.features.HFAFeatures;

import org.gvsig.raster.gdal.io.features.IDRISIFeatures;

import org.gvsig.raster.gdal.io.features.ILWIS_MprFeatures;

import org.gvsig.raster.gdal.io.features.Jpeg2000Features;

import org.gvsig.raster.gdal.io.features.PNM_PgmFeatures;

import org.gvsig.raster.gdal.io.features.PNM_PpmFeatures;

import org.gvsig.raster.impl.buffer.DefaultDataServerWriter;

import org.gvsig.raster.impl.buffer.RasterBuffer;

import org.gvsig.raster.impl.process.RasterTask;

import org.gvsig.raster.impl.process.RasterTaskQueue;

import org.gvsig.raster.impl.store.ParamImpl;

import org.gvsig.raster.impl.store.ParamsImpl;

import org.gvsig.raster.impl.store.WriteFileFormatFeatures;

import org.gvsig.raster.impl.store.properties.DataStoreColorInterpretation;

import org.gvsig.raster.impl.store.writer.DefaultRasterWriter;

import org.gvsig.raster.util.DefaultProviderServices;

import org.gvsig.tools.ToolsLocator;

import org.gvsig.tools.extensionpoint.ExtensionPoint;

import org.gvsig.tools.extensionpoint.ExtensionPointManager;

/**

 * Driver para la escritura a trav?s de Gdal.

 * Puede exportar un fichero de un formato a otro desde un GeoRasterFile

 * en cualquier formato soportado por la lectura a un formato que este incluido

 * en la lista supportedDrv.

 *

 * Puede salvar a disco en un formato que este incluido en la lista supportedDrv

 * obteniendo los datos que van siendo servidos desde el cliente. Este cliente

 * debe implementar un DataServerWriter o tener un objeto que lo implemente. Inicialmente

 * le pasar? los par?metros de la imagen de salida y cuando el driver comience a

 * escribir le ir? solicitando m?s a trav?s del m?todo readData de DataServerWriter.

 * El cliente ser? el que lleve el control de lo que va sirviendo y lo que le queda

 * por servir.

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

 */

public class GdalWriter extends DefaultRasterWriter {

    private static final Logger logger = LoggerFactory.getLogger(GdalWriter.class);

        /**

         *

         */

        public static void register() {

                DefaultProviderServices pInfo = (DefaultProviderServices)RasterLocator.getManager().getProviderServices();

                ExtensionPointManager extensionPoints = ToolsLocator.getExtensionPointManager();

                ExtensionPoint point = extensionPoints.get("RasterWriter");

                point.append("tif", "", GdalWriter.class);

                pInfo.getFileFeature().put("tif", new GTiffFeatures());

                point.append("img", "", GdalWriter.class);

                pInfo.getFileFeature().put("img", new HFAFeatures());

                point.append("bmp", "", GdalWriter.class);

                pInfo.getFileFeature().put("bmp", new BMPFeatures());

                point.append("pgm", "", GdalWriter.class);

                pInfo.getFileFeature().put("pgm", new PNM_PgmFeatures());

                point.append("ppm", "", GdalWriter.class);

                pInfo.getFileFeature().put("ppm", new PNM_PpmFeatures());

                point.append("mpl", "", GdalWriter.class);

                pInfo.getFileFeature().put("mpl", new ILWIS_MprFeatures());

                point.append("rst", "", GdalWriter.class);

                pInfo.getFileFeature().put("rst", new IDRISIFeatures());

                point.append("jp2", "", GdalWriter.class);

                pInfo.getFileFeature().put("jp2", new Jpeg2000Features());

                //La exportaci?n no es correcta del todo

//                point.append("rmf", "", GdalWriter.class);

//                pInfo.getFileFeature().put("rmf", new RMFFeatures());

                //No salva datos. Siempre sale negra la imagen

                //point.register("aux", GdalWriter.class);

                //fileFeature.put("aux", new PAuxFeatures());

        }

        private GdalDriver                                 drv;

        private GdalDataset                                                         dstDataset = null;

        private GdalRasterBand                                         rband = null;

        private GeoTransform                                         geot = null; //Datos de georeferenciaci?n

        //private OGRSpatialReference                         oSRS; //Datos de proyecci?n

        private GdalBuffer[]                                        bufBands = null;

        private int                                                         nBlocks = 0; //N?mero de bloques en Y en el que se divide la imagen para escribir

        private int                                                         anchoResto = 0; //Tama?o del ?ltimo bloque de la imagen.

        private boolean                                                        write = true; //Cuando est? a true se puede escribir en la imagen de salida. Si est? a false el proceso es interrumpido

        private int                                                         dataType = RasterBuffer.TYPE_UNDEFINED;

        /**

         * Carga los par?metros de este driver.

         * @param ident

         */

        public void loadParams(String ident) {

                WriteFileFormatFeatures wfff = (WriteFileFormatFeatures)pInfo.getFileFeature().get(ident);

                wfff.loadParams();

                driverParams = (ParamsImpl)wfff.getParams();

        }

        public String getProviderName() {

                return GdalProvider.NAME;

        }

        /**

         * Constructor para la obtenci?n de par?metros del driver

         * @param fileName

         */

        public GdalWriter(String fileName) {

                ident = fileUtil.getExtensionFromFileName(fileName);

                driver = ((WriteFileFormatFeatures)pInfo.getFileFeature().get(ident)).getDriverName();

                loadParams(ident);

        }

        /**

         * Constructor para salvar datos servidos por el cliente

         * @param dataWriter               Objeto servidor de datos para el driver de escritura

         * @param outFileName              Fichero de salida

         * @param nBands            N?mero de bandas

         * @param at                Transformaci?n afin

         * @param outSizeX                          Tama?o de salida en X

         * @param outSizeY                        Tama?o de salida en Y

         * @param dataType                        Tipo de dato

         * @param params

         * @param proj

         * @throws GdalException

         * @throws IOException

         */

        public GdalWriter(        DataServerWriter dataWriter,

                        String outFileName,

                        Integer nBands,

                        AffineTransform at,

                        Integer outSizeX,

                        Integer outSizeY,

                        Integer dataType,

                        Params params,

                        IProjection proj) throws GdalException, IOException {

                this(dataWriter, outFileName, nBands, at, outSizeX, outSizeY, dataType, params, proj, new Boolean(true));

        }

        /**

         * Constructor para salvar datos servidos por el cliente

         * @param dataWriter               Objeto servidor de datos para el driver de escritura

         * @param outFileName

         * @param nBands

         * @param at

         * @param outFilename              Fichero de salida

         * @param outSizeX                          Tama?o de salida en X

         * @param outSizeY                        Tama?o de salida en Y

         * @param dataType                        Tipo de dato

         * @param params

         * @param proj

         * @param geo                                Flag que dice si se salva con georreferenciaci?n o sin ella

         * @throws GdalException

         * @throws IOException

         */

        public GdalWriter(        DataServerWriter dataWriter,

                        String outFileName,

                        Integer nBands,

                        AffineTransform at,

                        Integer outSizeX,

                        Integer outSizeY,

                        Integer dataType,

                        Params params,

                        IProjection proj,

                        Boolean geo)throws GdalException, IOException {

                this.proj = proj;

                ident = outFileName.toLowerCase().substring(outFileName.lastIndexOf(".") + 1);

                driver = ((WriteFileFormatFeatures)pInfo.getFileFeature().get(ident)).getDriverName();

                this.dataType = dataType.intValue();

                this.at = at;

                percent = 0;

                this.dataWriter = dataWriter;

                this.outFileName = outFileName;

                this.sizeWindowX = outSizeX.intValue();

                this.sizeWindowY = outSizeY.intValue();

                if ((sizeWindowX < 0) || (sizeWindowY < 0))

                        throw new IOException("Tama?o del fichero de salida erroneo.");

                this.nBands = nBands.intValue();

                //Calculamos la georeferenciaci?n a partir del extend pasado por el cliente.

                geot = new GeoTransform();

                geot.adfgeotransform[0] = at.getTranslateX();

                geot.adfgeotransform[3] = at.getTranslateY();

                geot.adfgeotransform[1] = at.getScaleX();

                geot.adfgeotransform[5] = at.getScaleY();

                geot.adfgeotransform[2] = at.getShearX();

                geot.adfgeotransform[4] = at.getShearY();

                String outRmf = outFileName.substring(0, outFileName.lastIndexOf("."));

                if(geo.booleanValue())

                        rasterUtil.saveGeoInfo(outRmf, at, new Point2D.Double(sizeWindowX, sizeWindowY));

                if(params == null)

                        loadParams(ident);

                else

                        if(params instanceof ParamsImpl)

                                this.driverParams = (ParamsImpl)params;

                init();

        }

        /**

         * A?ade la proyecci?n Wkt con la que salvar.

         * @param wkt

         * @throws GdalException

         */

        public void setWkt(String wkt) {

                if(dstDataset != null && wkt != null && wkt.compareTo("unknown") != 0)

                        try {

                                dstDataset.setProjection(wkt);

                        } catch (GdalException e) {

                                System.err.println("Proyecci?n Wkt no asignada en GdalWriter");

                                return;

                        }

        }

        /**

         * Asigna el tipo de driver con el que se salvar? la imagen

         * @param drvType        Tipo de driver

         */

        public void setDriverType(String drvType) {

                this.driver = drvType;

        }

        /**

         * Creaci?n del dataset de destino.

         * @throws EcwException

         */

        private void init() throws GdalException {

                //Controlamos que el tipo de driver sea correcto

                if (driver == null)

                        throw new GdalException("Tipo de driver sin especificar.");

                boolean okdrvtype = false;

                String[] types = pInfo.getWriteDriversType();

                for (int i = 0; i < pInfo.getWriteNTypes(); i++)

                        if (driver.equals(types[i]))

                                okdrvtype = true;

                if (okdrvtype == false)

                        throw new GdalException("El tipo de driver " + driver + " no est? soportado por GdalWriter.");

                //Obtenemos el driver y creamos el dataset del destino

                drv = GdalDataset.getDriverByName(driver);

                if (dstDataset != null) {

                        dstDataset.close();

                        dstDataset = null;

                }

                dstDataset = drv.create(outFileName, sizeWindowX, sizeWindowY,

                                nBands, GdalDataSource.getGdalTypeFromRasterBufType(dataType), gdalParamsFromRasterParams(driverParams));

                dstDataset.setGeoTransform(geot);

                int blockSize = RasterLibrary.blockHeight;

                if(dataWriter.getBuffer() != null && dataWriter.getBuffer().isCached())

                        blockSize = dataWriter.getBuffer().getBlockHeight();

                nBlocks = (sizeWindowY / blockSize);

                anchoResto = sizeWindowY - (nBlocks * blockSize);

        }

        /**

         * @param fileName

         * @throws GdalException

         */

        public void anotherFile(String fileName) throws GdalException {

                dstDataset = drv.create(fileName, sizeWindowX, sizeWindowY,

                                nBands, GdalDataSource.getGdalTypeFromRasterBufType(dataType), gdalParamsFromRasterParams(driverParams));

        }

        /**

         * Convierte los par?metros obtenidos desde el objeto params a parametros

         * comprensibles por la librer?a gdal

         * @param p Params

         * @return Array de par?metros

         */

        public String[] gdalParamsFromRasterParams(Params p) {

                if (p == null)

                        return null;

                ArrayList<String> paramList = new ArrayList<String>();

                ParamImpl phot = (ParamImpl)p.getParamById("photometric");

                if (phot != null)

                        paramList.add("PHOTOMETRIC=" + phot.getList()[((Integer) phot.getDefaultValue()).intValue()]);

                ParamImpl inter = (ParamImpl)p.getParamById("interleave");

                if (inter != null)

                        paramList.add("INTERLEAVE=" + inter.getList()[((Integer) inter.getDefaultValue()).intValue()]);

                ParamImpl comp = (ParamImpl)p.getParamById("compression");// GIF LZW, ...

                if (comp != null)

                        paramList.add("COMPRESS=" + comp.getList()[((Integer) comp.getDefaultValue()).intValue()]);

                ParamImpl comp1 = (ParamImpl)p.getParamById("compress"); // HFA (YES, NO)

                if (comp1 != null)

                        paramList.add("COMPRESS=" + comp1.getList()[((Integer) comp1.getDefaultValue()).intValue()]);

                ParamImpl rrd = (ParamImpl)p.getParamById("rrd");

                if (rrd != null)

                        paramList.add("HFA_USE_RRD=" + rrd.getList()[((Integer) rrd.getDefaultValue()).intValue()]);

                ParamImpl mtw = (ParamImpl)p.getParamById("Mtw");

                if (mtw != null)

                        paramList.add("MTW=" + mtw.getList()[((Integer) mtw.getDefaultValue()).intValue()]);

                ParamImpl tw = (ParamImpl)p.getParamById("Tile Width");

                if (tw != null)

                        paramList.add("BLOCKXSIZE=" + tw.getList()[((Integer) tw.getDefaultValue()).intValue()]);

                ParamImpl th = (ParamImpl)p.getParamById("Tile Height");

                if (th != null)

                        paramList.add("BLOCKYSIZE=" + th.getList()[((Integer) th.getDefaultValue()).intValue()]);

                ParamImpl qt = (ParamImpl)p.getParamById("quality");

                if (qt != null)

                        paramList.add("QUALITY=" + qt.getDefaultValue());

                ParamImpl prog = (ParamImpl)p.getParamById("progressive");

                if (prog != null)

                        paramList.add("PROGRESSIVE=" + prog.getDefaultValue());

                if (paramList.size() == 0)

                        return null;

                String[] result = new String[paramList.size()];

                for (int i = 0; i < result.length; i++)

                        result[i] = (String) paramList.get(i);

                return result;

        }

        /**

         * Escritura de datos tipo Byte.

         * @param sizeY Alto del bloque que se escribe.

         * @param posicionY Posici?ny a partir desde donde se comienza.

         */

        public void writeByteBand(int sizeY, int posicionY) {

                byte[][] buftmp = dataWriter.readByteData(sizeWindowX, sizeY);

                for(int iBand = 0; iBand < nBands; iBand ++)

                        bufBands[iBand].buffByte = new byte[buftmp[iBand].length];

                //Escribimos el bloque destino

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

                        for (int i = 0; i < buftmp[iBand].length; i++)

                                bufBands[iBand].buffByte[i] = buftmp[iBand][i];

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

                        try {

                                rband = dstDataset.getRasterBand(iBand + 1);

                                rband.writeRaster(0, posicionY, sizeWindowX, sizeY, bufBands[iBand], GdalDataset.GDT_Byte);

                                bufBands[iBand].buffByte = null;

                        } catch (GdalException e) {

                                //No se est? escribiendo ...

                        }

                buftmp = null;

        }

        /**

         * Escritura de datos tipo Short.

         * @param sizeY Alto del bloque que se escribe.

         * @param posicionY Posici?ny a partir desde donde se comienza.

         */

        public void writeShortBand(int sizeY, int posicionY) {

                short[][] buftmp = dataWriter.readShortData(sizeWindowX, sizeY);

                for(int iBand = 0; iBand < nBands; iBand ++)

                        bufBands[iBand].buffShort = new short[buftmp[iBand].length];

                //Escribimos el bloque destino

                for (int iBand = 0; iBand < nBands; iBand++)

                        for (int i = 0; i < buftmp[iBand].length; i++)

                                bufBands[iBand].buffShort[i] = buftmp[iBand][i];

                for (int iBand = 0; iBand < nBands; iBand++)

                        try {

                                rband = dstDataset.getRasterBand(iBand + 1);

                                rband.writeRaster(0, posicionY, sizeWindowX, sizeY, bufBands[iBand], GdalDataset.GDT_Int16);

                                bufBands[iBand].buffShort = null;

                        } catch (GdalException e) {

                                //No se est? escribiendo ...

                        }

                buftmp = null;

        }

        /**

         * Escritura de datos tipo Int.

         * @param sizeY Alto del bloque que se escribe.

         * @param posicionY Posici?ny a partir desde donde se comienza.

         */

        public void writeIntBand(int sizeY, int posicionY) {

                int[][] buftmp = dataWriter.readIntData(sizeWindowX, sizeY);

                for(int iBand = 0; iBand < nBands; iBand ++)

                        bufBands[iBand].buffInt = new int[buftmp[iBand].length];

                //Escribimos el bloque destino

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

                        for (int i = 0; i < buftmp[iBand].length; i++)

                                bufBands[iBand].buffInt[i] = buftmp[iBand][i];

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

                        try {

                                rband = dstDataset.getRasterBand(iBand + 1);

                                rband.writeRaster(0, posicionY, sizeWindowX, sizeY, bufBands[iBand], GdalDataset.GDT_Int32);

                                bufBands[iBand].buffInt = null;

                        } catch (GdalException e) {

                                //No se est? escribiendo ...

                        }

                buftmp = null;

        }

        /**

         * Escritura de datos tipo Float.

         * @param sizeY Alto del bloque que se escribe.

         * @param posicionY Posici?ny a partir desde donde se comienza.

         */

        public void writeFloatBand(int sizeY, int posicionY) {

                float[][] buftmp = dataWriter.readFloatData(sizeWindowX, sizeY);

                for(int iBand = 0; iBand < nBands; iBand ++)

                        bufBands[iBand].buffFloat = new float[buftmp[iBand].length];

                //Escribimos el bloque destino

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

                        for (int i = 0; i < buftmp[iBand].length; i++)

                                bufBands[iBand].buffFloat[i] = buftmp[iBand][i];

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

                        try {

                                rband = dstDataset.getRasterBand(iBand + 1);

                                rband.writeRaster(0, posicionY, sizeWindowX, sizeY, bufBands[iBand], GdalDataset.GDT_Float32);

                                bufBands[iBand].buffFloat = null;

                        } catch (GdalException e) {

                                //No se est? escribiendo ...

                        }

                buftmp = null;

        }

        /**

         * Escritura de datos tipo Double.

         * @param sizeY Alto del bloque que se escribe.

         * @param posicionY Posici?ny a partir desde donde se comienza.

         */

        public void writeDoubleBand(int sizeY, int posicionY) {

                double[][] buftmp = dataWriter.readDoubleData(sizeWindowX, sizeY);

                for(int iBand = 0; iBand < nBands; iBand ++)

                        bufBands[iBand].buffDouble = new double[buftmp[iBand].length];

                //Escribimos el bloque destino

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

                        for (int i = 0; i < buftmp[iBand].length; i++)

                                bufBands[iBand].buffDouble[i] = buftmp[iBand][i];

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

                        try {

                                rband = dstDataset.getRasterBand(iBand + 1);

                                rband.writeRaster(0, posicionY, sizeWindowX, sizeY, bufBands[iBand], GdalDataset.GDT_Float64);

                                bufBands[iBand].buffDouble = null;

                        } catch (GdalException e) {

                                //No se est? escribiendo ...

                        }

                buftmp = null;

        }

        /**

         * Escritura para tipo de dato ARGB.

         * @param sizeY Alto del bloque que se escribe.

         * @param posicionY Posici?ny a partir desde donde se comienza.

         * @throws ProcessInterruptedException

         * @throws OutOfMemoryError

         */

        public void writeARGBBand(int sizeY, int posicionY)

                        throws ProcessInterruptedException, OutOfMemoryError {

                int[] buftmp = dataWriter.readARGBData(sizeWindowX, sizeY, 0);

                for(int iBand = 0; iBand < nBands; iBand ++)

                        bufBands[iBand].buffByte = new byte[buftmp.length];

                //Escribimos el bloque destino

                for (int i = 0; i < buftmp.length; i++) {

                        bufBands[0].buffByte[i] = (byte) (((buftmp[i] & 0xff0000) >> 16) &

                                        0xff);

                        bufBands[1].buffByte[i] = (byte) (((buftmp[i] & 0xff00) >> 8) & 0xff);

                        bufBands[2].buffByte[i] = (byte) ((buftmp[i] & 0xff) & 0xff);

                }

                try {

                        rband = dstDataset.getRasterBand(1);

                        rband.writeRaster(0, posicionY, sizeWindowX, sizeY, bufBands[0],

                                        GdalDataset.GDT_Byte);

                        rband = dstDataset.getRasterBand(2);

                        rband.writeRaster(0, posicionY, sizeWindowX, sizeY, bufBands[1],

                                        GdalDataset.GDT_Byte);

                        rband = dstDataset.getRasterBand(3);

                        rband.writeRaster(0, posicionY, sizeWindowX, sizeY, bufBands[2],

                                        GdalDataset.GDT_Byte);

                } catch (GdalException e) {

                        e.printStackTrace();

                }

                bufBands[0].buffByte = null;

                bufBands[1].buffByte = null;

                bufBands[2].buffByte = null;

        }

        /**

         * Escribe tres bandas en el GDALRasterBand desde el DataServerWriter con una

         * altura definida por sizeY.

         * @param buftmp        Buffer

         * @param sizeY        Altura en pixels del bloque leido

         * @param posicionY        Posici?n y a partir de la cual se escribe en el GDALRasterBand destino

         */

        private void writeBands(int sizeY, int posicionY)

                        throws ProcessInterruptedException, OutOfMemoryError {

                //leemos el bloque origen

                switch(dataType){

                case RasterBuffer.TYPE_IMAGE:

                        writeARGBBand(sizeY, posicionY);

                        break;

                case RasterBuffer.TYPE_BYTE:

                        writeByteBand(sizeY, posicionY);

                        break;

                case RasterBuffer.TYPE_SHORT:

                        writeShortBand(sizeY, posicionY);

                        break;

                case RasterBuffer.TYPE_INT:

                        writeIntBand(sizeY, posicionY);

                        break;

                case RasterBuffer.TYPE_FLOAT:

                        writeFloatBand(sizeY, posicionY);

                        break;

                case RasterBuffer.TYPE_DOUBLE:

                        writeDoubleBand(sizeY, posicionY);

                        break;

                }

        }

        /**

         * Funci?n que gestiona la lectura desde el origen y la escritura

         * de Gdal sobre el fichero destino.

         * @param mode        Modo de escritura

         * @throws IOException

         */

        private void write(int mode) throws IOException, ProcessInterruptedException,

                        OutOfMemoryError {

                RasterTask task = RasterTaskQueue.get(Thread.currentThread().getId() + "");

                bufBands = new GdalBuffer[nBands];

                for(int iBand = 0; iBand < nBands; iBand ++)

                        bufBands[iBand] = new GdalBuffer();

                int blockSize = RasterLibrary.blockHeight;

                if(dataWriter instanceof DefaultDataServerWriter) {

                        Buffer source = ((DefaultDataServerWriter)dataWriter).getSource();

                        if(source.isCached()) {

                                blockSize = source.getBlockHeight();

                        }

                }

                percent = 0;

                nBlocks = (sizeWindowY / blockSize);

                double increment = (blockSize * 100) / (double)sizeWindowY;

                if (mode == DefaultRasterWriter.MODE_DATAWRITE)

                        for (int iBlock = 0; iBlock < nBlocks; iBlock++) {

                                if(task.getEvent() != null)

                                        task.manageEvent(task.getEvent());

                                int posicionY = iBlock * blockSize;

                                if(write)

                                        writeBands( blockSize, posicionY);

                                percent = (int)((iBlock + 1) * increment);

                        }

                if (anchoResto != 0)

                        if (mode == DefaultRasterWriter.MODE_DATAWRITE) {

                                if(task.getEvent() != null)

                                        task.manageEvent(task.getEvent());

                                int posicionY = nBlocks * blockSize;

                                if(write)

                                        writeBands(anchoResto, posicionY);

                                percent = (int)(nBlocks * increment);

                        }

        }

        /**

         * Realiza la funci?n de compresi?n a partir de un GeoRasterFile.

         * @throws IOException

         */

        public void fileWrite() throws IOException, ProcessInterruptedException {

                write(DefaultRasterWriter.MODE_FILEWRITE);

        }

        /**

         * Realiza una copia en el formato especificado.

         * @param driverDst

         * @param dst

         * @param src

         * @param bstrict

         * @param params

         * @throws IOException

         * @throws GdalException

         */

        public static void createCopy(GdalDriver driverDst, String dst, String src,

                        boolean bstrict, String[] params) throws IOException, GdalException {

                if (dst == null || src == null)

                        throw new IOException("No se ha asignado un fichero de entrada.");

                GdalProvider gdalFile;

                try {

                        GdalDataParameters par = new GdalDataParameters();

                        par.setFile(new File(src));

                        gdalFile = new GdalProvider(par, null);

                        GdalDataset dstDataset = driverDst.createCopy(dst, gdalFile.getNative(), bstrict, params);

                        if(        dst.endsWith(".jpg") ||

                                dst.endsWith(".jpeg") ||

                                dst.endsWith(".png"))

                                RasterLocator.getManager().getFileUtils().createWorldFile(dst, gdalFile.getExtent(), (int)gdalFile.getWidth(), (int)gdalFile.getHeight());

                        gdalFile.close();

                        dstDataset.close();

                } catch (NotSupportedExtensionException e) {

                        e.printStackTrace();

                }

        }

        /**

         * Realiza la escritura de datos con los datos que le pasa el cliente.

         * @throws IOException

         * @throws RmfSerializerException

         */

        public void dataWrite() throws IOException, ProcessInterruptedException,

                        OutOfMemoryError {

                if (dataWriter == null)

                        throw new IOException("No se ha obtenido un objeto de entrada para la escritura valido.");

                write(DefaultRasterWriter.MODE_DATAWRITE);

                if (driverParams.getParamById("tfw") != null &&

                                ((ParamImpl)driverParams.getParamById("tfw")).getDefaultValue() instanceof Boolean /*&&

                                ((Boolean) ((ParamImpl)driverParams.getParamById("tfw")).getDefaultValue()).booleanValue() == true*/)

                        if (at != null)

                                fileUtil.createWorldFile(this.outFileName, at, sizeWindowX, sizeWindowY);

                if (colorInterp != null)

                        try {

                RasterLocator.getManager().getProviderServices()

                    .saveObjectToRmfFile(outFileName, DataStoreColorInterpretation.class, colorInterp);

                        } catch (RmfSerializerException e) {

                                throw new IOException("No se ha podido guardar la interpretacion de color");

                        }

                this.savePrjFile(new File(this.outFileName), proj);

        }

        public void writeClose() {

                try {

                        if(bufBands != null) {

                                for (int i = 0; i < bufBands.length; i++) {

                                        bufBands[i].buffAPalette = null;

                                        bufBands[i].buffBPalette = null;

                                        bufBands[i].buffByte = null;

                                        bufBands[i].buffShort = null;

                                        bufBands[i].buffInt = null;

                                        bufBands[i].buffFloat = null;

                                        bufBands[i].buffDouble = null;

                                }

                        }

                        if(dstDataset != null)

                                dstDataset.close();

                } catch (GdalException e) {

                        e.printStackTrace();

                }

        }

        /**

         * Cancela el salvado de datos.

         */

        public void writeCancel() {

                write = false;

        }

        /**

         * Obtiene el valor a la variable write que estar? a true cuando se est? escribiendo

         *  o puede escribirse la imagen de salida. El cancelar la operaci?n de escritura

         * pondr? esta variable a false deteniendose la escritura y cerrandose el dataset

         * de salida.

         * @return True si puede escribirse y false si no puede

         */

        public boolean isWrite() {

                return write;

        }

        /**

         * Asigna el valor a la variable write que estar? a true cuando se est? escribiendo

         *  o puede escribirse la imagen de salida. El cancelar la operaci?n de escritura

         * pondr? esta variable a false deteniendose la escritura y cerrandose el dataset

         * de salida.

         * @param write Variable booleana. True si puede escribirse y false si no puede

         */

        public void setWrite(boolean write) {

                this.write = write;

        }

        /**

         * Asigna los par?metros del driver modificados por el cliente.

         * @param Params

         */

        public void setParams(Params params) {

                if(params instanceof ParamsImpl)

                        this.driverParams = (ParamsImpl)params;

                else

                        return;

                int blockSize = 256;

                try {

                        ParamImpl param = (ParamImpl)driverParams.getParamById("blocksize");

                        blockSize = Integer.parseInt(param.getList()[((Integer)param.getDefaultValue()).intValue()]);

                        nBlocks = (sizeWindowY / blockSize);

                        anchoResto = sizeWindowY - (nBlocks * blockSize);

                }catch(NumberFormatException e) {

                        //Se queda con el valor de inicializaci?n

                }

        }

        /*

         * (non-Javadoc)

         * @see java.lang.Object#finalize()

         */

        protected void finalize() throws Throwable {

                drv        = null;

                dstDataset = null;

                rband      = null;

                geot       = null;

                if(bufBands != null) {

                        for (int i = 0; i < bufBands.length; i++) {

                                bufBands[i].buffAPalette = null;

                                bufBands[i].buffBPalette = null;

                                bufBands[i].buffByte = null;

                                bufBands[i].buffShort = null;

                                bufBands[i].buffInt = null;

                                bufBands[i].buffFloat = null;

                                bufBands[i].buffDouble = null;

                        }

                }

                super.finalize();

        }

}