Mirrors/megabasterd
1
0
Fork 0
mirror of https://github.com/tonikelope/megabasterd.git synced 2025-05-20 16:27:12 +02:00
Code Issues Packages Projects Releases Wiki Activity

2.78b

Browse Source
This commit is contained in:
tonikelope 2018-01-06 14:39:01 +01:00
parent 15f7cf0f46
commit f902d321bd
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/megabasterd/ChunkUploader.java
View File

@ -37,6 +37,7 @@ import org.apache.http.impl.client.CloseableHttpClient;
*/ */
public class ChunkUploader implements Runnable, SecureSingleThreadNotifiable { public class ChunkUploader implements Runnable, SecureSingleThreadNotifiable {
public static final int FUTURE_TIMEOUT = 120;
private final int _id; private final int _id;
private final Upload _upload; private final Upload _upload;
private volatile boolean _exit; private volatile boolean _exit;
@ -192,7 +193,7 @@ public class ChunkUploader implements Runnable, SecureSingleThreadNotifiable {
if (!_exit) { if (!_exit) {
httpresponse = futureTask.get(HTTP_TIMEOUT + 5, TimeUnit.SECONDS); httpresponse = futureTask.get(FUTURE_TIMEOUT, TimeUnit.SECONDS);
} else { } else {

2
src/megabasterd/ChunkUploaderMono.java
View File

@ -212,7 +212,7 @@ public class ChunkUploaderMono extends ChunkUploader {
try { try {
httpresponse = futureTask.get(HTTP_TIMEOUT + 5, TimeUnit.SECONDS); httpresponse = futureTask.get(FUTURE_TIMEOUT, TimeUnit.SECONDS);
http_status = httpresponse.getStatusLine().getStatusCode(); http_status = httpresponse.getStatusLine().getStatusCode();