jeffcwj / okdownload-ext Goto Github PK

implementation 'com.liulishuo.okdownload:okdownload:1.0.7'
implementation 'com.liulishuo.okdownload:sqlite:1.0.7'
implementation 'in.xiandan:okdownload-ext:1.0.7'

OkDownloadExt.fix415Bug(this);

2021-06-01 21:40:31.206 9284-9284/ W/System.err: java.io.IOException: The current offset on block-info isn't update correct, 58953018 != 69212754 on 0
2021-06-01 21:40:31.206 9284-9284/ W/System.err:     at com.liulishuo.okdownload.core.file.MultiPointOutputStream.inspectComplete(MultiPointOutputStream.java:263)
2021-06-01 21:40:31.207 9284-9284/ W/System.err:     at com.liulishuo.okdownload.core.interceptor.BreakpointInterceptor.interceptFetch(BreakpointInterceptor.java:123)
2021-06-01 21:40:31.207 9284-9284/ W/System.err:     at com.liulishuo.okdownload.core.download.DownloadChain.processFetch(DownloadChain.java:220)
2021-06-01 21:40:31.207 9284-9284/ W/System.err:     at com.liulishuo.okdownload.core.interceptor.RetryInterceptor.interceptFetch(RetryInterceptor.java:57)
2021-06-01 21:40:31.207 9284-9284/ W/System.err:     at com.liulishuo.okdownload.core.download.DownloadChain.processFetch(DownloadChain.java:220)
2021-06-01 21:40:31.207 9284-9284/ W/System.err:     at com.liulishuo.okdownload.core.download.DownloadChain.start(DownloadChain.java:195)
2021-06-01 21:40:31.207 9284-9284/ W/System.err:     at com.liulishuo.okdownload.core.download.DownloadChain.run(DownloadChain.java:247)
2021-06-01 21:40:31.207 9284-9284/ W/System.err:     at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:462)
2021-06-01 21:40:31.207 9284-9284/ W/System.err:     at java.util.concurrent.FutureTask.run(FutureTask.java:266)
2021-06-01 21:40:31.207 9284-9284/ W/System.err:     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1167)
2021-06-01 21:40:31.207 9284-9284/ W/System.err:     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:641)
2021-06-01 21:40:31.207 9284-9284/ W/System.err:     at java.lang.Thread.run(Thread.java:919)

package com.liulishuo.okdownload.core.file

import com.liulishuo.okdownload.DownloadTask
import com.liulishuo.okdownload.core.breakpoint.BreakpointInfo
import com.liulishuo.okdownload.core.breakpoint.DownloadStore
import java.io.IOException

class CustomProcessFileStrategy : ProcessFileStrategy() {
    override fun createProcessStream(task: DownloadTask,
                                     info: BreakpointInfo,
                                     store: DownloadStore): MultiPointOutputStream {
        return CustomMultiPointOutputStream(task, info, store)
    }


    class CustomMultiPointOutputStream : MultiPointOutputStream {
        private var task: DownloadTask? = null

        constructor(task: DownloadTask, info: BreakpointInfo, store: DownloadStore, syncRunnable: Runnable?) : super(task, info, store, syncRunnable){
            this.task = task
        }

        constructor(task: DownloadTask, info: BreakpointInfo, store: DownloadStore) : super(task, info, store, null){
            this.task = task
        }

        @Synchronized
        @Throws(IOException::class)
        override fun close(blockIndex: Int) {
            val outputStream = outputStreamMap[blockIndex]
            if (outputStream != null) {
                outputStream.close()
                synchronized(noSyncLengthMap) {
                    // make sure the length of noSyncLengthMap is equal to outputStreamMap
                    outputStreamMap.remove(blockIndex)
                    noSyncLengthMap.remove(blockIndex)
                }
            }
        }
    }
}

OkDownload.setSingletonInstance(
        new OkDownload.Builder(getApplicationContext())
                .processFileStrategy(new CustomProcessFileStrategy())
                .build());

StatusUtil.isCompleted(task)

implementation 'com.liulishuo.okdownload:sqlite:1.0.7'