starred/audiobookshelf-app
1
0
Fork 0
mirror of https://github.com/advplyr/audiobookshelf-app.git synced 2026-08-29 14:47:21 +02:00
Code Issues 454 Packages Projects Releases 10 Wiki Activity

Increase download chunk size to 512 KB

Browse Source
This commit is contained in:
Nicholas Wallace
2026-07-20 20:05:18 -07:00
parent 58fbfca645
commit f8424c03fd
1 changed files with 21 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
android/app/src/main/java/com/audiobookshelf/app/managers/InternalDownloadManager.kt
+21 -12
View File
@@ -34,9 +34,7 @@ class InternalDownloadManager(
.url(url) .url(url)
.addHeader("Accept-Encoding", "identity") .addHeader("Accept-Encoding", "identity")
.addHeader("Authorization", "Bearer $token") .addHeader("Authorization", "Bearer $token")
.apply { .apply { if (existingBytes > 0L) header("Range", "bytes=$existingBytes-") }
if (existingBytes > 0L) header("Range", "bytes=$existingBytes-")
}
.build() .build()
val call = client.newCall(request) val call = client.newCall(request)
call.enqueue( call.enqueue(
@@ -49,14 +47,21 @@ class InternalDownloadManager(
override fun onResponse(call: Call, response: Response) { override fun onResponse(call: Call, response: Response) {
response.use { response.use {
try { try {
if (response.code == 416 && expectedSize > 0L && existingBytes == expectedSize) { if (response.code == 416 && expectedSize > 0L && existingBytes == expectedSize
) {
progressCallback.onProgress(existingBytes, 100L) progressCallback.onProgress(existingBytes, 100L)
progressCallback.onComplete(false) progressCallback.onComplete(false)
return return
} }
val append = existingBytes > 0L && response.code == 206 && hasExpectedRange(response, existingBytes) val append =
existingBytes > 0L &&
response.code == 206 &&
hasExpectedRange(response, existingBytes)
if (existingBytes > 0L && !append && response.code != 200) { if (existingBytes > 0L && !append && response.code != 200) {
Log.e(tag, "Invalid resume response ${response.code} for offset $existingBytes") Log.e(
tag,
"Invalid resume response ${response.code} for offset $existingBytes"
)
progressCallback.onComplete(true) progressCallback.onComplete(true)
return return
} }
@@ -70,8 +75,7 @@ class InternalDownloadManager(
val responseLength = response.body!!.contentLength() val responseLength = response.body!!.contentLength()
val totalLength = val totalLength =
if (expectedSize > 0L) expectedSize if (expectedSize > 0L) expectedSize
else if (responseLength >= 0L) startingBytes + responseLength else if (responseLength >= 0L) startingBytes + responseLength else 0L
else 0L
FileOutputStream(destinationFile, append).use { output -> FileOutputStream(destinationFile, append).use { output ->
response.body!!.byteStream().use { input -> response.body!!.byteStream().use { input ->
@@ -80,17 +84,22 @@ class InternalDownloadManager(
while (true) { while (true) {
val read = input.read(buffer) val read = input.read(buffer)
if (read < 0) break if (read < 0) break
if (!hasAvailableSpace()) throw IOException("Download paused to preserve free storage") if (!hasAvailableSpace())
throw IOException("Download paused to preserve free storage")
output.write(buffer, 0, read) output.write(buffer, 0, read)
totalBytes += read totalBytes += read
val progress = if (totalLength > 0L) (totalBytes * 100L) / totalLength else 0L val progress =
if (totalLength > 0L) (totalBytes * 100L) / totalLength else 0L
progressCallback.onProgress(totalBytes, progress.coerceAtMost(100L)) progressCallback.onProgress(totalBytes, progress.coerceAtMost(100L))
} }
} }
} }
if (expectedSize > 0L && destinationFile.length() != expectedSize) { if (expectedSize > 0L && destinationFile.length() != expectedSize) {
Log.e(tag, "Downloaded size ${destinationFile.length()} did not match $expectedSize") Log.e(
tag,
"Downloaded size ${destinationFile.length()} did not match $expectedSize"
)
progressCallback.onComplete(true) progressCallback.onComplete(true)
} else { } else {
progressCallback.onComplete(false) progressCallback.onComplete(false)
@@ -114,7 +123,7 @@ class InternalDownloadManager(
} }
private companion object { private companion object {
const val CHUNK_SIZE = 8 * 1024 const val CHUNK_SIZE = 512 * 1024 // 512 KB
val CONTENT_RANGE = Regex("bytes (\\d+)-(\\d+)/(?:\\d+|\\*)") val CONTENT_RANGE = Regex("bytes (\\d+)-(\\d+)/(?:\\d+|\\*)")
val client = val client =
OkHttpClient.Builder() OkHttpClient.Builder()