| Index: adblockplussbrowser/src/org/adblockplus/sbrowser/contentblocker/engine/Downloader.java |
| =================================================================== |
| --- a/adblockplussbrowser/src/org/adblockplus/sbrowser/contentblocker/engine/Downloader.java |
| +++ b/adblockplussbrowser/src/org/adblockplus/sbrowser/contentblocker/engine/Downloader.java |
| @@ -26,30 +26,29 @@ import java.nio.charset.StandardCharsets |
| import java.util.HashMap; |
| import java.util.HashSet; |
| import java.util.Map; |
| import java.util.Map.Entry; |
| import java.util.concurrent.LinkedBlockingQueue; |
| import java.util.concurrent.TimeUnit; |
| import java.util.concurrent.locks.ReentrantLock; |
| import android.annotation.SuppressLint; |
| -import android.content.Context; |
| import android.util.Log; |
| @SuppressLint("DefaultLocale") |
| final class Downloader |
| { |
| private static final int MAX_RETRIES = 5; |
| private static final String TAG = Downloader.class.getSimpleName(); |
| private final Engine engine; |
| private final ReentrantLock accessLock = new ReentrantLock(); |
| private Thread downloaderThread; |
| - private LinkedBlockingQueue<DownloadJob> downloadJobs = new LinkedBlockingQueue<>(); |
| - private HashSet<String> enqueuedIds = new HashSet<>(); |
| + private final LinkedBlockingQueue<DownloadJob> downloadJobs = new LinkedBlockingQueue<>(); |
| + private final HashSet<String> enqueuedIds = new HashSet<>(); |
| private boolean downloaderEnabled = true; |
| private Downloader(final Engine engine) |
| { |
| this.engine = engine; |
| } |
| void lock() |
| @@ -72,22 +71,19 @@ final class Downloader |
| this.downloaderEnabled = true; |
| this.unlock(); |
| } |
| static void download(final DownloadJob job) throws IOException |
| { |
| final HttpURLConnection connection = (HttpURLConnection) job.url.openConnection(); |
| connection.setRequestMethod("GET"); |
| - if (job.headers != null) |
| + for (final Entry<String, String> e : job.headers.entrySet()) |
| { |
| - for (final Entry<String, String> e : job.headers.entrySet()) |
| - { |
| - connection.addRequestProperty(e.getKey(), e.getValue()); |
| - } |
| + connection.addRequestProperty(e.getKey(), e.getValue()); |
| } |
| connection.connect(); |
| job.responseCode = connection.getResponseCode(); |
| job.responseHeaders.clear(); |
| job.responseText = null; |
| for (int i = 1;; i++) |
| @@ -125,17 +121,17 @@ final class Downloader |
| } |
| } |
| finally |
| { |
| this.unlock(); |
| } |
| } |
| - public static Downloader create(final Context context, final Engine engine) |
| + public static Downloader create(final Engine engine) |
| { |
| final Downloader downloader = new Downloader(engine); |
| downloader.downloaderThread = new Thread(new DownloaderHandler(downloader)); |
| downloader.downloaderThread.setDaemon(true); |
| downloader.downloaderThread.start(); |
| return downloader; |
| @@ -244,17 +240,17 @@ final class Downloader |
| private static class DownloadJob |
| { |
| private final URL url; |
| private final String id; |
| private final HashMap<String, String> headers = new HashMap<>(); |
| private int retryCount = 0; |
| private int responseCode = 0; |
| - private HashMap<String, String> responseHeaders = new HashMap<>(); |
| + private final HashMap<String, String> responseHeaders = new HashMap<>(); |
| private String responseText = null; |
| public DownloadJob(final URL url, final String id, final Map<String, String> headers) |
| { |
| this.url = url; |
| this.id = id; |
| if (headers != null) |
| { |