org/objectweb/proactive/core/filetransfer/FileBlock.java

/* 
 * ################################################################
 * 
 * ProActive: The Java(TM) library for Parallel, Distributed, 
 *            Concurrent computing with Security and Mobility
 * 
 * Copyright (C) 1997-2007 INRIA/University of Nice-Sophia Antipolis
 * Contact: proactive@objectweb.org
 * 
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or any later version.
 *  
 * This library 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
 * Lesser General Public License for more details.
 * 
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307
 * USA
 *  
 *  Initial developer(s):               The ProActive Team
 *                        http://www.inria.fr/oasis/ProActive/contacts.html
 *  Contributor(s): 
 * 
 * ################################################################
 */ 
package org.objectweb.proactive.core.filetransfer;

/*
 * ################################################################
 *
 * ProActive: The Java(TM) library for Parallel, Distributed, Concurrent
 * computing with Security and Mobility
 *
 * Copyright (C) 1997-2002 INRIA/University of Nice-Sophia Antipolis Contact:
 * proactive-support@inria.fr
 *
 * This library is free software; you can redistribute it and/or modify it under
 * the terms of the GNU Lesser General Public License as published by the Free
 * Software Foundation; either version 2.1 of the License, or any later version.
 *
 * This library 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 Lesser General Public License for more
 * details.
 *
 * You should have received a copy of the GNU Lesser General Public License
 * along with this library; if not, write to the Free Software Foundation, Inc.,
 * 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
 *
 * Initial developer(s): The ProActive Team
 * http://www.inria.fr/oasis/ProActive/contacts.html Contributor(s):
 *
 * ################################################################
 */
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.IOException;
import java.io.Serializable;

import org.apache.log4j.Logger;
import org.objectweb.proactive.core.util.log.Loggers;
import org.objectweb.proactive.core.util.log.ProActiveLogger;


public class FileBlock implements Serializable {
    protected static Logger logger = ProActiveLogger.getLogger(Loggers.FILETRANSFER);
    public static final int DEFAULT_BLOCK_SIZE = 256 * 1024; //Bytes
    private byte[] buffer;
    private int usage;
    private long offset;
    private int blockSize;
    private Exception exception;

    public FileBlock() {
    }

    public FileBlock(long offset) {
        this(offset, DEFAULT_BLOCK_SIZE);
    }

    public FileBlock(long offset, int blockSize) {
        this.offset = offset;
        this.blockSize = blockSize;
        this.buffer = new byte[blockSize];

        this.exception = null;
        this.usage = 0;
    }

    public void loadNextBlock(BufferedInputStream bis)
        throws IOException {
        if (bis == null) {
            throw new IllegalArgumentException(
                "Can not handle null BufferInputStream parameter.");
        }

        try {
            usage = bis.read(buffer, 0, blockSize);
            offset += usage;
        } catch (IOException e) {
            usage = 0;
            throw e;
        }
    }

    public void saveCurrentBlock(BufferedOutputStream bos)
        throws IOException {
        if (bos == null) {
            throw new IllegalArgumentException(
                "Can not handle null BufferedOutputStream parameter.");
        }

        bos.write(buffer, 0, usage);
    }

    public long getOffset() {
        return offset;
    }

    public int getBlockSize() {
        return blockSize;
    }

    public Exception getException() {
        return exception;
    }

    public boolean hasException() {
        return exception != null;
    }

    public void setException(Exception e) {
        exception = e;
    }
}

---