Rietveld Code Review Tool
Help | Bug tracker | Discussion group | Source code

Delta Between Two Patch Sets: src/org/adblockplus/android/AndroidWebRequest.java

Issue 5697499218051072: Usage of new API, cleanups (reduced) (Closed)
Left Patch Set: Removed newly added neetutils code Created April 25, 2014, 9:31 a.m.
Right Patch Set: Even more review issues fixed. Created April 28, 2014, 10:18 a.m.
Left:
Right:
Use n/p to move between diff chunks; N/P to move between comments.
Jump to:
Left: Side by side diff | Download
Right: Side by side diff | Download
LEFTRIGHT
1 /* 1 /*
2 * This file is part of Adblock Plus <http://adblockplus.org/>, 2 * This file is part of Adblock Plus <http://adblockplus.org/>,
3 * Copyright (C) 2006-2014 Eyeo GmbH 3 * Copyright (C) 2006-2014 Eyeo GmbH
4 * 4 *
5 * Adblock Plus is free software: you can redistribute it and/or modify 5 * Adblock Plus is free software: you can redistribute it and/or modify
6 * it under the terms of the GNU General Public License version 3 as 6 * it under the terms of the GNU General Public License version 3 as
7 * published by the Free Software Foundation. 7 * published by the Free Software Foundation.
8 * 8 *
9 * Adblock Plus is distributed in the hope that it will be useful, 9 * Adblock Plus is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of 10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
(...skipping 16 matching lines...) Expand all
27 import org.adblockplus.libadblockplus.ServerResponse; 27 import org.adblockplus.libadblockplus.ServerResponse;
28 import org.adblockplus.libadblockplus.WebRequest; 28 import org.adblockplus.libadblockplus.WebRequest;
29 import org.adblockplus.libadblockplus.ServerResponse.NsStatus; 29 import org.adblockplus.libadblockplus.ServerResponse.NsStatus;
30 30
31 import android.util.Log; 31 import android.util.Log;
32 32
33 public class AndroidWebRequest extends WebRequest 33 public class AndroidWebRequest extends WebRequest
34 { 34 {
35 public final String TAG = Utils.getTag(WebRequest.class); 35 public final String TAG = Utils.getTag(WebRequest.class);
36 36
37 private static final int INITIAL_BUFFER_SIZE = 65536;
38 private static final int BUFFER_GROWTH_DELTA = 65536;
39
37 @Override 40 @Override
38 public ServerResponse httpGET(final String urlStr, final List<HeaderEntry> hea ders) 41 public ServerResponse httpGET(final String urlStr, final List<HeaderEntry> hea ders)
39 { 42 {
40 try 43 try
41 { 44 {
42 final URL url = new URL(urlStr); 45 final URL url = new URL(urlStr);
43 Log.d(this.TAG, "Downloading from: " + url); 46 Log.d(this.TAG, "Downloading from: " + url);
44 47
45 final HttpURLConnection connection = (HttpURLConnection) url.openConnectio n(); 48 final HttpURLConnection connection = (HttpURLConnection) url.openConnectio n();
46 connection.setRequestMethod("GET"); 49 connection.setRequestMethod("GET");
47 connection.connect(); 50 connection.connect();
48 51
49 final ServerResponse response = new ServerResponse(); 52 final ServerResponse response = new ServerResponse();
50 response.setResponseStatus(connection.getResponseCode()); 53 response.setResponseStatus(connection.getResponseCode());
51 54
52 if (response.getResponseStatus() == 200) 55 if (response.getResponseStatus() == 200)
53 { 56 {
54 final InputStream in = connection.getInputStream(); 57 final InputStream in = connection.getInputStream();
55 58
56 final byte[] buffer = new byte[4096]; 59 final byte[] buffer = new byte[4096];
57 60
58 byte[] out = new byte[65536]; 61 byte[] out = new byte[INITIAL_BUFFER_SIZE];
59 62
60 int pos = 0; 63 int pos = 0;
61 for (;;) 64 for (;;)
62 { 65 {
63 final int read = in.read(buffer); 66 final int read = in.read(buffer);
64 if (read < 0) 67 if (read < 0)
65 { 68 {
66 break; 69 break;
67 } 70 }
68 if (pos + read > out.length) 71 if (pos + read > out.length)
69 { 72 {
70 final byte[] old = out; 73 final byte[] old = out;
71 out = new byte[out.length + 65536]; 74 out = new byte[out.length + BUFFER_GROWTH_DELTA];
Felix Dahlke 2014/04/28 07:29:01 I think 65536 should be a constant here.
72 System.arraycopy(old, 0, out, 0, pos); 75 System.arraycopy(old, 0, out, 0, pos);
73 } 76 }
74 System.arraycopy(buffer, 0, out, pos, read); 77 System.arraycopy(buffer, 0, out, pos, read);
75 pos += read; 78 pos += read;
76 } 79 }
77 80
78 connection.disconnect(); 81 connection.disconnect();
79 82
80 response.setStatus(NsStatus.OK); 83 response.setStatus(NsStatus.OK);
81 response.setResponse(new String(out, 0, pos, "utf-8")); 84 response.setResponse(new String(out, 0, pos, "utf-8"));
82 } 85 }
83 else 86 else
84 { 87 {
85 response.setStatus(NsStatus.ERROR_FAILURE); 88 response.setStatus(NsStatus.ERROR_FAILURE);
86 } 89 }
87 return response; 90 return response;
88 } 91 }
89 catch (final Throwable t) 92 catch (final Throwable t)
90 { 93 {
91 throw new AdblockPlusException("WebRequest failed", t); 94 throw new AdblockPlusException("WebRequest failed", t);
92 } 95 }
93 } 96 }
94 } 97 }
LEFTRIGHT

Powered by Google App Engine
This is Rietveld