Fixed local path NULL when making favourite a file not down ; fixed change of local...

[pub/Android/ownCloud.git] / src / eu / alefzero / webdav / ChunkFromFileChannelRequestEntity.java

diff --git a/src/eu/alefzero/webdav/ChunkFromFileChannelRequestEntity.java b/src/eu/alefzero/webdav/ChunkFromFileChannelRequestEntity.java
index b7ab261..1316315 100644 (file)
--- a/src/eu/alefzero/webdav/ChunkFromFileChannelRequestEntity.java
+++ b/src/eu/alefzero/webdav/ChunkFromFileChannelRequestEntity.java
@@ -18,6 +18,7 @@
 
 package eu.alefzero.webdav;
 
 
 package eu.alefzero.webdav;
 

+import java.io.File;

 import java.io.IOException;
 import java.io.OutputStream;
 import java.nio.ByteBuffer;
 import java.io.IOException;
 import java.io.OutputStream;
 import java.nio.ByteBuffer;


@@ -46,23 +47,27 @@ public class ChunkFromFileChannelRequestEntity implements RequestEntity {
     //private final File mFile;
     private final FileChannel mChannel;
     private final String mContentType;
     //private final File mFile;
     private final FileChannel mChannel;
     private final String mContentType;

-    private final long mSize;
+    private final long mChunkSize;
+    private final File mFile;

     private long mOffset;
     private long mOffset;

-    Set<OnDatatransferProgressListener> mListeners = new HashSet<OnDatatransferProgressListener>();
+    private long mTransferred;
+    Set<OnDatatransferProgressListener> mDataTransferListeners = new HashSet<OnDatatransferProgressListener>();

     private ByteBuffer mBuffer = ByteBuffer.allocate(4096);
 
     private ByteBuffer mBuffer = ByteBuffer.allocate(4096);
 

-    public ChunkFromFileChannelRequestEntity(final FileChannel channel, final String contentType, long size) {
+    public ChunkFromFileChannelRequestEntity(final FileChannel channel, final String contentType, long chunkSize, final File file) {

         super();
         if (channel == null) {
             throw new IllegalArgumentException("File may not be null");
         }
         super();
         if (channel == null) {
             throw new IllegalArgumentException("File may not be null");
         }

-        if (size <= 0) {
-            throw new IllegalArgumentException("Size must be greater than zero");
+        if (chunkSize <= 0) {
+            throw new IllegalArgumentException("Chunk size must be greater than zero");

         }
         mChannel = channel;
         mContentType = contentType;
         }
         mChannel = channel;
         mContentType = contentType;

-        mSize = size;
+        mChunkSize = chunkSize;
+        mFile = file;

         mOffset = 0;
         mOffset = 0;

+        mTransferred = 0;

     }
     
     public void setOffset(long offset) {
     }
     
     public void setOffset(long offset) {


@@ -71,9 +76,9 @@ public class ChunkFromFileChannelRequestEntity implements RequestEntity {
     
     public long getContentLength() {
         try {
     
     public long getContentLength() {
         try {

-            return Math.min(mSize, mChannel.size() - mChannel.position());
+            return Math.min(mChunkSize, mChannel.size() - mChannel.position());

         } catch (IOException e) {
         } catch (IOException e) {

-            return mSize;
+            return mChunkSize;

         }
     }
 
         }
     }
 


@@ -86,15 +91,15 @@ public class ChunkFromFileChannelRequestEntity implements RequestEntity {
     }
     
     public void addOnDatatransferProgressListener(OnDatatransferProgressListener listener) {
     }
     
     public void addOnDatatransferProgressListener(OnDatatransferProgressListener listener) {

-        mListeners.add(listener);
+        mDataTransferListeners.add(listener);

     }
     
     public void addOnDatatransferProgressListeners(Collection<OnDatatransferProgressListener> listeners) {
     }
     
     public void addOnDatatransferProgressListeners(Collection<OnDatatransferProgressListener> listeners) {

-        mListeners.addAll(listeners);
+        mDataTransferListeners.addAll(listeners);

     }
     
     public void removeOnDatatransferProgressListener(OnDatatransferProgressListener listener) {
     }
     
     public void removeOnDatatransferProgressListener(OnDatatransferProgressListener listener) {

-        mListeners.remove(listener);
+        mDataTransferListeners.remove(listener);

     }
     
     
     }
     
     


@@ -104,13 +109,16 @@ public class ChunkFromFileChannelRequestEntity implements RequestEntity {
         
        try {
             mChannel.position(mOffset);
         
        try {
             mChannel.position(mOffset);

-            while (mChannel.position() < mOffset + mSize && mChannel.position() < mChannel.size()) {
+            long size = mFile.length();
+            if (size == 0) size = -1;
+            while (mChannel.position() < mOffset + mChunkSize && mChannel.position() < mChannel.size()) {

                 readCount = mChannel.read(mBuffer);
                 out.write(mBuffer.array(), 0, readCount);
                 mBuffer.clear();
                 readCount = mChannel.read(mBuffer);
                 out.write(mBuffer.array(), 0, readCount);
                 mBuffer.clear();

-                it = mListeners.iterator();
+                mTransferred += readCount;
+                it = mDataTransferListeners.iterator();

                 while (it.hasNext()) {
                 while (it.hasNext()) {

-                    it.next().onTransferProgress(readCount);
+                    it.next().onTransferProgress(readCount, mTransferred, size, mFile.getName());

                 }
             }
             
                 }
             }