+/* ownCloud Android client application
+ * Copyright (C) 2012 Bartek Przybylski
+ *
+ * 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 3 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, see <http://www.gnu.org/licenses/>.
+ *
+ */
+
package eu.alefzero.webdav;
import java.io.File;
import java.io.RandomAccessFile;
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;
-import java.nio.channels.FileLock;
import java.util.Collection;
import java.util.HashSet;
import java.util.Iterator;
final File mFile;
final String mContentType;
- Set<OnDatatransferProgressListener> mListeners = new HashSet<OnDatatransferProgressListener>();
+ Set<OnDatatransferProgressListener> mDataTransferListeners = new HashSet<OnDatatransferProgressListener>();
public FileRequestEntity(final File file, final String contentType) {
super();
}
public void addOnDatatransferProgressListener(OnDatatransferProgressListener listener) {
- mListeners.add(listener);
+ mDataTransferListeners.add(listener);
}
public void addOnDatatransferProgressListeners(Collection<OnDatatransferProgressListener> listeners) {
- mListeners.addAll(listeners);
+ mDataTransferListeners.addAll(listeners);
}
public void removeOnDatatransferProgressListener(OnDatatransferProgressListener listener) {
- mListeners.remove(listener);
+ mDataTransferListeners.remove(listener);
}
public void writeRequest(final OutputStream out) throws IOException {
//byte[] tmp = new byte[4096];
ByteBuffer tmp = ByteBuffer.allocate(4096);
- int i = 0;
+ int readResult = 0;
// TODO(bprzybylski): each mem allocation can throw OutOfMemoryError we need to handle it
// globally in some fashionable manner
- RandomAccessFile raf = new RandomAccessFile(mFile, "rw");
+ RandomAccessFile raf = new RandomAccessFile(mFile, "r");
FileChannel channel = raf.getChannel();
- FileLock lock = channel.tryLock();
Iterator<OnDatatransferProgressListener> it = null;
+ long transferred = 0;
+ long size = mFile.length();
+ if (size == 0) size = -1;
try {
- while ((i = channel.read(tmp)) >= 0) {
- out.write(tmp.array(), 0, i);
+ while ((readResult = channel.read(tmp)) >= 0) {
+ out.write(tmp.array(), 0, readResult);
tmp.clear();
- it = mListeners.iterator();
+ transferred += readResult;
+ it = mDataTransferListeners.iterator();
while (it.hasNext()) {
- it.next().onTransferProgress(i);
+ it.next().onTransferProgress(readResult, transferred, size, mFile.getName());
}
}
throw new RuntimeException("Ugly solution to workaround the default policy of retries when the server falls while uploading ; temporal fix; really", io);
} finally {
- lock.release();
channel.close();
raf.close();
}
}
-}
\ No newline at end of file
+}