nutomic/syncthing-android
1
0
Fork 0
mirror of https://github.com/syncthing/syncthing-android.git synced 2024-11-23 12:51:16 +00:00
Code Releases Activity

Retry GET requests at least 10 times

Browse source
This commit is contained in:
Lode Hoste 2015-03-22 23:51:39 +01:00
parent 07027af420
commit 8e014ce0cd
1 changed files with 35 additions and 27 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

62
src/main/java/com/nutomic/syncthingandroid/syncthing/GetTask.java
View file

@ -49,34 +49,42 @@ public class GetTask extends AsyncTask<String, Void, String> {
*/ */
@Override @Override
protected String doInBackground(String... params) { protected String doInBackground(String... params) {
String fullUri = params[0] + params[1]; // Retry at most 10 times before failing
HttpClient httpclient = new DefaultHttpClient(); for (int i = 0; i < 10; i++) {
if (params.length == 5) { String fullUri = params[0] + params[1];
LinkedList<NameValuePair> urlParams = new LinkedList<>(); HttpClient httpclient = new DefaultHttpClient();
urlParams.add(new BasicNameValuePair(params[3], params[4])); if (params.length == 5) {
fullUri += "?" + URLEncodedUtils.format(urlParams, HTTP.UTF_8); LinkedList<NameValuePair> urlParams = new LinkedList<>();
} urlParams.add(new BasicNameValuePair(params[3], params[4]));
HttpGet get = new HttpGet(fullUri); fullUri += "?" + URLEncodedUtils.format(urlParams, HTTP.UTF_8);
get.addHeader(new BasicHeader(RestApi.HEADER_API_KEY, params[2]));
try {
HttpResponse response = httpclient.execute(get);
HttpEntity entity = response.getEntity();
if (entity != null) {
InputStream is = entity.getContent();
BufferedReader br = new BufferedReader(new InputStreamReader(is));
String line;
String result = "";
while ((line = br.readLine()) != null) {
result += line;
}
br.close();
return result;
} }
} catch (IOException e) { HttpGet get = new HttpGet(fullUri);
Log.w(TAG, "Failed to call Rest API at " + fullUri, e); get.addHeader(new BasicHeader(RestApi.HEADER_API_KEY, params[2]));
try {
HttpResponse response = httpclient.execute(get);
HttpEntity entity = response.getEntity();
if (entity != null) {
InputStream is = entity.getContent();
BufferedReader br = new BufferedReader(new InputStreamReader(is));
String line;
String result = "";
while ((line = br.readLine()) != null) {
result += line;
}
br.close();
return result;
}
} catch (IOException e) {
Log.w(TAG, "Failed to call Rest API at " + fullUri, e);
}
try {
// Don't push the API too hard
Thread.sleep(100);
} catch (InterruptedException e) { }
Log.w(TAG, "Retrying GetTask Rest API call ("+i+")");
} }
return null; return null;
} }