Application: gvSIG desktop » gvSIG raster

package org.gvsig.raster.lib.buffer.impl;

import java.io.IOException;

import java.nio.Buffer;

import org.gvsig.raster.lib.buffer.api.Band;

import org.gvsig.raster.lib.buffer.api.BandInfo;

import org.gvsig.raster.lib.buffer.api.BandNotification;

import org.gvsig.raster.lib.buffer.api.BandPageManager;

import org.gvsig.raster.lib.buffer.api.BufferLocator;

import org.gvsig.raster.lib.buffer.api.NoData;

import org.gvsig.raster.lib.buffer.impl.exceptions.CopyFromBandException;

/**

 * @author fdiaz

 *

 */

public abstract class AbstractPaginatedBand extends AbstractBand implements Band{

    protected Buffer data;

    protected int firstRowOfPage;

    protected int rowsPerPage;

    protected BandPageManager pageManager;

    private boolean loaded;

    protected static final int MAX_PREFERED_SIZE = 10485760; // 10MB;

    /**

     * @param rows

     * @param columns

     * @param noData

     * @param pageManager

     */

    public AbstractPaginatedBand(int rows, int columns, NoData noData, BandPageManager pageManager) {

        this.rows = rows;

        this.columns = columns;

        this.loaded=false;

        calculateRowsPerPage();

        if (noData == null) {

            this.noData = BufferLocator.getBufferManager().createNoData(null, null);

        } else {

            this.noData = noData;

        }

        this.pageManager = pageManager;

    }

    private void calculateRowsPerPage(){

        rowsPerPage = MAX_PREFERED_SIZE/(this.columns*getDataSize());

        if(rowsPerPage<1){

            rowsPerPage = 1;

        }

    }

    /**

     * @param value

     * @return

     */

    protected Object nullValueToNoData(Object value) {

        if (value == null) {

            if (getNoData().isDefined()) {

                value = getNoData().getValue();

            } else {

                // Do nothing, no data value is undefined

                return null;

            }

        }

        return value;

    }

    @Override

    public void copyFrom(Band source) throws CopyFromBandException {

        doCopyFrom(source);

        notifyObservers(new DefaultBandNotification(BandNotification.COPY_FROM, new Object[]{source}));

    }

    protected void doCopyFrom(Band source) throws CopyFromBandException {

        if (this.getColumns() != source.getColumns() || this.getRows() != source.getRows()

            || this.getDataType()!=source.getDataType() ) {

            throw new CopyFromBandException(source, this);

        }

        Object rowBuffer = this.createRowBuffer();

        for(int row = 0; row<=this.rows; row++){

            source.fetchRow(row, rowBuffer);

            this.putRow(row, rowBuffer);

        }

    }

    protected void loadPage(int row) {

        if (loaded && row >= firstRowOfPage

            && row < firstRowOfPage + rowsPerPage) {

            return;

        }

        loaded=false;

        saveCurrentPage();

        int currentPage = row / rowsPerPage; //Divisi?n entera

        firstRowOfPage = currentPage * rowsPerPage;

        try {

            int rowsInPage = rowsPerPage;

            if(firstRowOfPage + rowsPerPage > this.rows){

                rowsInPage = this.rows - firstRowOfPage;

            }

            this.pageManager.load(data, firstRowOfPage, rowsInPage, this.getDataType());

            loaded=true;

        } catch (IOException e) {

            throw new RuntimeException("Can't save current page", e);

        }

    }

    protected void saveCurrentPage() {

        try {

            int rowsInPage = rowsPerPage;

            if(firstRowOfPage + rowsPerPage > this.rows){

                rowsInPage = this.rows - firstRowOfPage;

            }

            this.pageManager.save(data, firstRowOfPage, rowsInPage, this.getDataType());

        } catch (UnsupportedOperationException e) {

            // Do nothing, operation not supported

        } catch (IOException e) {

            throw new RuntimeException("Can't save current page", e);

        }

    }

    protected abstract int getDataSize();

    @Override

    public boolean isReadOnly() {

        if(this.pageManager==null){

            return false;

        }

        return !this.pageManager.isSupportedSave();

    }

    @Override

    public boolean isPaginated() {

        return true;

    }

    @Override

    public BandInfo getBandInfo() {

        return this.pageManager == null ? null : this.pageManager.getBandInfo();

    }

}