GpsXtraDownloaderpublic class GpsXtraDownloader extends Object | A class for downloading GPS XTRA data.
{@hide} |
| Fields Summary |
|---|
| private static final String | TAG | | private static final boolean | DEBUG | | private static final String | DEFAULT_USER_AGENT | | private final android.content.Context | mContext | | private final String[] | mXtraServers | | private int | mNextServerIndex | | private final String | mUserAgent |
| Constructors Summary |
|---|
GpsXtraDownloader(android.content.Context context, Properties properties)
mContext = context;
// read XTRA servers from the Properties object
int count = 0;
String server1 = properties.getProperty("XTRA_SERVER_1");
String server2 = properties.getProperty("XTRA_SERVER_2");
String server3 = properties.getProperty("XTRA_SERVER_3");
if (server1 != null) count++;
if (server2 != null) count++;
if (server3 != null) count++;
// Set User Agent from properties, if possible.
String agent = properties.getProperty("XTRA_USER_AGENT");
if (TextUtils.isEmpty(agent)) {
mUserAgent = DEFAULT_USER_AGENT;
} else {
mUserAgent = agent;
}
if (count == 0) {
Log.e(TAG, "No XTRA servers were specified in the GPS configuration");
mXtraServers = null;
return;
} else {
mXtraServers = new String[count];
count = 0;
if (server1 != null) mXtraServers[count++] = server1;
if (server2 != null) mXtraServers[count++] = server2;
if (server3 != null) mXtraServers[count++] = server3;
// randomize first server
Random random = new Random();
mNextServerIndex = random.nextInt(count);
}
|
| Methods Summary |
|---|
| protected byte[] | doDownload(java.lang.String url, boolean isProxySet, java.lang.String proxyHost, int proxyPort)
if (DEBUG) Log.d(TAG, "Downloading XTRA data from " + url);
AndroidHttpClient client = null;
try {
if (DEBUG) Log.d(TAG, "XTRA user agent: " + mUserAgent);
client = AndroidHttpClient.newInstance(mUserAgent);
HttpUriRequest req = new HttpGet(url);
if (isProxySet) {
HttpHost proxy = new HttpHost(proxyHost, proxyPort);
ConnRouteParams.setDefaultProxy(req.getParams(), proxy);
}
req.addHeader(
"Accept",
"*/*, application/vnd.wap.mms-message, application/vnd.wap.sic");
req.addHeader(
"x-wap-profile",
"http://www.openmobilealliance.org/tech/profiles/UAPROF/ccppschema-20021212#");
HttpResponse response = client.execute(req);
StatusLine status = response.getStatusLine();
if (status.getStatusCode() != 200) { // HTTP 200 is success.
if (DEBUG) Log.d(TAG, "HTTP error: " + status.getReasonPhrase());
return null;
}
HttpEntity entity = response.getEntity();
byte[] body = null;
if (entity != null) {
try {
if (entity.getContentLength() > 0) {
body = new byte[(int) entity.getContentLength()];
DataInputStream dis = new DataInputStream(entity.getContent());
try {
dis.readFully(body);
} finally {
try {
dis.close();
} catch (IOException e) {
Log.e(TAG, "Unexpected IOException.", e);
}
}
}
} finally {
if (entity != null) {
entity.consumeContent();
}
}
}
return body;
} catch (Exception e) {
if (DEBUG) Log.d(TAG, "error " + e);
} finally {
if (client != null) {
client.close();
}
}
return null;
| | byte[] | downloadXtraData()
String proxyHost = Proxy.getHost(mContext);
int proxyPort = Proxy.getPort(mContext);
boolean useProxy = (proxyHost != null && proxyPort != -1);
byte[] result = null;
int startIndex = mNextServerIndex;
if (mXtraServers == null) {
return null;
}
// load balance our requests among the available servers
while (result == null) {
result = doDownload(mXtraServers[mNextServerIndex], useProxy, proxyHost, proxyPort);
// increment mNextServerIndex and wrap around if necessary
mNextServerIndex++;
if (mNextServerIndex == mXtraServers.length) {
mNextServerIndex = 0;
}
// break if we have tried all the servers
if (mNextServerIndex == startIndex) break;
}
return result;
|
|
