mirror of
https://github.com/eclipse-sailing-analytics/sailing-analytics.git
synced 2026-10-27 06:17:27 +00:00
TRACKING APP: dont send fixes if last send hasnt terminated with success/failure
This commit is contained in:
Lukas Zielinski committed
1 parent
9130622c46
commit
0d2b106dcf
1 file changed
+287
-304
+287
-304
@@ -34,87 +34,92 @@ import com.sap.sailing.android.tracking.app.valueobjects.GpsFix;
|
||||
/**
|
||||
* Service that handles sending of GPS-fixes (fixes) to the Sailing-API.
|
||||
*
|
||||
* It checks, after a certain time-interval has passed, if any fixes are available in the database
|
||||
* and attempts to send them batch-wise.
|
||||
* It checks, after a certain time-interval has passed, if any fixes are
|
||||
* available in the database and attempts to send them batch-wise.
|
||||
*
|
||||
* (There are two strategies for sending, depending on whether tracking is running. If it's running,
|
||||
* only fixes for the current event are being sent. If not, it tries to send fixes for previous events,
|
||||
* as well. Assuming there are older unsent fixes that for some reason have not been sent.)
|
||||
* (There are two strategies for sending, depending on whether tracking is
|
||||
* running. If it's running, only fixes for the current event are being sent. If
|
||||
* not, it tries to send fixes for previous events, as well. Assuming there are
|
||||
* older unsent fixes that for some reason have not been sent.)
|
||||
*
|
||||
* It keeps track of when the last successful sending occurred and, if no new data is available
|
||||
* (i.e., if tracking is disabled), ends itself after a certain period. It relies on being restarted
|
||||
* by the {@link TrackingService}.
|
||||
* It keeps track of when the last successful sending occurred and, if no new
|
||||
* data is available (i.e., if tracking is disabled), ends itself after a
|
||||
* certain period. It relies on being restarted by the {@link TrackingService}.
|
||||
*
|
||||
* It also ends itself when connectivity is lost. In that case it relies on being restarted by
|
||||
* the {@link ConnectivityChangedReceiver}.
|
||||
* It also ends itself when connectivity is lost. In that case it relies on
|
||||
* being restarted by the {@link ConnectivityChangedReceiver}.
|
||||
*
|
||||
* It switches into a power saving mode, if a certain battery discharge is reached. It does, however,
|
||||
* not do so, if the device is plugged in (= when it is charging). The power saving mode causes the
|
||||
* time-interval between check- and transmit-cycles to be increased to conserve power.
|
||||
* It switches into a power saving mode, if a certain battery discharge is
|
||||
* reached. It does, however, not do so, if the device is plugged in (= when it
|
||||
* is charging). The power saving mode causes the time-interval between check-
|
||||
* and transmit-cycles to be increased to conserve power.
|
||||
*
|
||||
* @author Lukas Zielinski
|
||||
*
|
||||
*/
|
||||
public class TransmittingService extends Service {
|
||||
|
||||
|
||||
private static final String TAG = TransmittingService.class.getName();
|
||||
|
||||
|
||||
private final int UPDATE_BATCH_SIZE = 1000;
|
||||
private final int UPDATE_INTERVAL_DEFAULT = 3000;
|
||||
private final int UPDATE_INTERVAL_POWERSAVE_MODE = 30000;
|
||||
private final long AUTO_END_SERVICE_AFTER_NANO_PASSED = 10000000000L; // 10 sec
|
||||
private final long AUTO_END_SERVICE_AFTER_NANO_PASSED = 10000000000L; // 10
|
||||
// sec
|
||||
private final float BATTERY_POWER_SAVE_TRESHOLD = 0.2f;
|
||||
|
||||
|
||||
private int currentUpdateInterval = UPDATE_INTERVAL_DEFAULT;
|
||||
|
||||
|
||||
private boolean sendingAttempted = false;
|
||||
private boolean lastTransmissionFailed = false;
|
||||
private long lastTransmissionTimestamp = 0;
|
||||
|
||||
|
||||
private AppPreferences prefs;
|
||||
private Timer timer;
|
||||
private boolean timerRunning;
|
||||
|
||||
private APIConnectivityListener apiConnectivityListener;
|
||||
private final IBinder transmittingBinder = new TransmittingBinder();
|
||||
|
||||
|
||||
private APIConnectivityListener apiConnectivityListener;
|
||||
private final IBinder transmittingBinder = new TransmittingBinder();
|
||||
|
||||
/**
|
||||
* True if sending, because if sending takes longer a new attempt should not
|
||||
* be made.
|
||||
*/
|
||||
private static boolean currentlySending = false;
|
||||
|
||||
@Override
|
||||
public IBinder onBind(Intent intent) {
|
||||
prefs = new AppPreferences(this);
|
||||
|
||||
if (!timerRunning)
|
||||
{
|
||||
|
||||
if (!timerRunning) {
|
||||
startTimer();
|
||||
}
|
||||
|
||||
|
||||
return transmittingBinder;
|
||||
}
|
||||
|
||||
|
||||
@Override
|
||||
public int onStartCommand(Intent intent, int flags, int startId) {
|
||||
|
||||
|
||||
prefs = new AppPreferences(this);
|
||||
|
||||
|
||||
if (intent != null) {
|
||||
if (intent.getAction() != null) {
|
||||
if (intent.getAction().equals(getString(R.string.transmitting_service_start))) {
|
||||
if (!timerRunning)
|
||||
{
|
||||
startTimer();
|
||||
if (!timerRunning) {
|
||||
startTimer();
|
||||
}
|
||||
} else {
|
||||
stopTimer();
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
} else {
|
||||
stopTimer();
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
return Service.START_STICKY;
|
||||
}
|
||||
|
||||
|
||||
private void startTimer() {
|
||||
timer = new Timer();
|
||||
timer.start();
|
||||
@@ -122,168 +127,151 @@ public class TransmittingService extends Service {
|
||||
if (BuildConfig.DEBUG) {
|
||||
ExLog.i(this, "TIMER", "Background update-timer start");
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
|
||||
private void stopTimer() {
|
||||
if (timer != null)
|
||||
{
|
||||
timer.stop();
|
||||
if (timer != null) {
|
||||
timer.stop();
|
||||
timerRunning = false;
|
||||
if (BuildConfig.DEBUG) {
|
||||
ExLog.i(this, "TIMER", "Background update-timer stop");
|
||||
}
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
private void markSuccessfulTransmission()
|
||||
{
|
||||
|
||||
private void markSuccessfulTransmission() {
|
||||
currentlySending = false;
|
||||
|
||||
if (BuildConfig.DEBUG) {
|
||||
ExLog.i(this, "TRANSMISSION", "markSuccessfulTransmission");
|
||||
}
|
||||
|
||||
|
||||
lastTransmissionFailed = false;
|
||||
lastTransmissionTimestamp = System.nanoTime();
|
||||
|
||||
|
||||
reportApiConnectivity(APIConnectivity.reachableTransmissionSuccess);
|
||||
}
|
||||
|
||||
private void markFailedTransmission()
|
||||
{
|
||||
|
||||
private void markFailedTransmission() {
|
||||
currentlySending = false;
|
||||
|
||||
if (BuildConfig.DEBUG) {
|
||||
ExLog.i(this, "TRANSMISSION", "markFailedTransmission");
|
||||
}
|
||||
|
||||
|
||||
lastTransmissionFailed = true;
|
||||
lastTransmissionTimestamp = 0;
|
||||
|
||||
if (isConnected())
|
||||
{
|
||||
|
||||
if (isConnected()) {
|
||||
reportApiConnectivity(APIConnectivity.reachableTransmissionError);
|
||||
} else {
|
||||
reportApiConnectivity(APIConnectivity.notReachable);
|
||||
}
|
||||
else
|
||||
{
|
||||
reportApiConnectivity(APIConnectivity.notReachable);
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* If time interval has passed without any transmission, the service can turn
|
||||
* itself off. Same for
|
||||
* If time interval has passed without any transmission, the service can
|
||||
* turn itself off. Same for
|
||||
*
|
||||
* @return
|
||||
*/
|
||||
private boolean serviceCanShutItselfDown()
|
||||
{
|
||||
private boolean serviceCanShutItselfDown() {
|
||||
long currentNanoTime = System.nanoTime();
|
||||
|
||||
if (BuildConfig.DEBUG)
|
||||
{
|
||||
|
||||
if (BuildConfig.DEBUG) {
|
||||
ExLog.i(this, "TRANSMISSION", "serviceCanShutItselfDown?");
|
||||
ExLog.i(this, "TRANSMISSION", "DELTA:" + (currentNanoTime - lastTransmissionTimestamp));
|
||||
}
|
||||
|
||||
// if network is not connected, shutdown. ConnevtivityChangedReceiver should restart us.
|
||||
if (!isConnected())
|
||||
{
|
||||
enabledConnectivityReceiver(); // make sure ConnectivityReceiver is running
|
||||
|
||||
// if network is not connected, shutdown. ConnevtivityChangedReceiver
|
||||
// should restart us.
|
||||
if (!isConnected()) {
|
||||
enabledConnectivityReceiver(); // make sure ConnectivityReceiver is
|
||||
// running
|
||||
return true;
|
||||
}
|
||||
|
||||
// if we had a failure, never go to sleep until data is sent successfully.
|
||||
if (lastTransmissionFailed)
|
||||
{
|
||||
if (BuildConfig.DEBUG)
|
||||
{
|
||||
ExLog.i(this, "TRANSMISSION", "returning false, have failed transmission");
|
||||
|
||||
// if we had a failure, never go to sleep until data is sent
|
||||
// successfully.
|
||||
if (lastTransmissionFailed) {
|
||||
if (BuildConfig.DEBUG) {
|
||||
ExLog.i(this, "TRANSMISSION", "returning false, have failed transmission");
|
||||
}
|
||||
|
||||
|
||||
return false;
|
||||
}
|
||||
|
||||
if (!sendingAttempted)
|
||||
{
|
||||
if (BuildConfig.DEBUG)
|
||||
{
|
||||
ExLog.i(this, "TRANSMISSION", "returning true, no sending attempt");
|
||||
|
||||
if (!sendingAttempted) {
|
||||
if (BuildConfig.DEBUG) {
|
||||
ExLog.i(this, "TRANSMISSION", "returning true, no sending attempt");
|
||||
}
|
||||
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
if (currentNanoTime - lastTransmissionTimestamp > AUTO_END_SERVICE_AFTER_NANO_PASSED)
|
||||
{
|
||||
if (BuildConfig.DEBUG)
|
||||
{
|
||||
ExLog.i(this, "TRANSMISSION", "returning true, timeout");
|
||||
|
||||
if (currentNanoTime - lastTransmissionTimestamp > AUTO_END_SERVICE_AFTER_NANO_PASSED) {
|
||||
if (BuildConfig.DEBUG) {
|
||||
ExLog.i(this, "TRANSMISSION", "returning true, timeout");
|
||||
}
|
||||
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
if (BuildConfig.DEBUG)
|
||||
{
|
||||
ExLog.i(this, "TRANSMISSION", "returning false, don't terminate");
|
||||
|
||||
if (BuildConfig.DEBUG) {
|
||||
ExLog.i(this, "TRANSMISSION", "returning false, don't terminate");
|
||||
}
|
||||
|
||||
|
||||
return false;
|
||||
}
|
||||
|
||||
private void timerFired()
|
||||
{
|
||||
|
||||
private void timerFired() {
|
||||
float batteryPct = getBatteryPercentage();
|
||||
boolean batteryIsCharging = prefs.getBatteryIsCharging();
|
||||
|
||||
if ( prefs.getEnergySavingEnabledByUser() ||
|
||||
(batteryPct < BATTERY_POWER_SAVE_TRESHOLD && !batteryIsCharging))
|
||||
{
|
||||
if (BuildConfig.DEBUG)
|
||||
{
|
||||
ExLog.i(this, "POWER-LEVELS", "in power saving mode");
|
||||
boolean batteryIsCharging = prefs.getBatteryIsCharging();
|
||||
|
||||
if (prefs.getEnergySavingEnabledByUser()
|
||||
|| (batteryPct < BATTERY_POWER_SAVE_TRESHOLD && !batteryIsCharging)) {
|
||||
if (BuildConfig.DEBUG) {
|
||||
ExLog.i(this, "POWER-LEVELS", "in power saving mode");
|
||||
}
|
||||
|
||||
|
||||
currentUpdateInterval = UPDATE_INTERVAL_POWERSAVE_MODE;
|
||||
}
|
||||
else
|
||||
{
|
||||
if (BuildConfig.DEBUG)
|
||||
{
|
||||
ExLog.i(this, "POWER-LEVELS", "in default power mode");
|
||||
} else {
|
||||
if (BuildConfig.DEBUG) {
|
||||
ExLog.i(this, "POWER-LEVELS", "in default power mode");
|
||||
}
|
||||
|
||||
|
||||
currentUpdateInterval = UPDATE_INTERVAL_DEFAULT;
|
||||
}
|
||||
|
||||
|
||||
sendFixesToAPI(null);
|
||||
reportUnsentGPSFixesCount(DatabaseHelper.getInstance().getNumberOfUnsentGPSFixes(getBaseContext()));
|
||||
reportUnsentGPSFixesCount(DatabaseHelper.getInstance().getNumberOfUnsentGPSFixes(
|
||||
getBaseContext()));
|
||||
}
|
||||
|
||||
private boolean getTrackingServiceIsCurrentlyTracking()
|
||||
{
|
||||
|
||||
private boolean getTrackingServiceIsCurrentlyTracking() {
|
||||
return prefs.getTrackerIsTracking();
|
||||
}
|
||||
|
||||
|
||||
private void sendFixesToAPI(List<String> failedHosts) {
|
||||
|
||||
// first, lets fetch all unsent fixes
|
||||
List<GpsFix> fixes = DatabaseHelper.getInstance().getUnsentFixes(getBaseContext(), failedHosts, UPDATE_BATCH_SIZE);
|
||||
List<GpsFix> fixes = DatabaseHelper.getInstance().getUnsentFixes(getBaseContext(),
|
||||
failedHosts, UPDATE_BATCH_SIZE);
|
||||
// store ids so we can delete the rows later
|
||||
ArrayList<String> ids = new ArrayList<String>();
|
||||
|
||||
|
||||
// create JSON
|
||||
JSONArray jsonArray = new JSONArray();
|
||||
String currentEventId = null;
|
||||
String host = null;
|
||||
|
||||
for (GpsFix fix : fixes)
|
||||
{
|
||||
if (currentEventId == null)
|
||||
{
|
||||
JSONArray jsonArray = new JSONArray();
|
||||
String currentEventId = null;
|
||||
String host = null;
|
||||
|
||||
for (GpsFix fix : fixes) {
|
||||
if (currentEventId == null) {
|
||||
currentEventId = fix.eventId;
|
||||
host = fix.host;
|
||||
}
|
||||
|
||||
|
||||
if (currentEventId.equals(fix.eventId)) {
|
||||
// still have more unsent Gps-Fixes for this event.
|
||||
ids.add(String.valueOf(fix.id));
|
||||
@@ -296,8 +284,7 @@ public class TransmittingService extends Service {
|
||||
json.put("longitude", fix.longitude);
|
||||
json.put("latitude", fix.latitude);
|
||||
} catch (JSONException ex) {
|
||||
ExLog.i(this, TAG, "Error while building geolocation json "
|
||||
+ ex.getMessage());
|
||||
ExLog.i(this, TAG, "Error while building geolocation json " + ex.getMessage());
|
||||
}
|
||||
|
||||
jsonArray.put(json);
|
||||
@@ -306,197 +293,198 @@ public class TransmittingService extends Service {
|
||||
// collection, proceed with sending.
|
||||
break;
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
|
||||
if (jsonArray.length() > 0) {
|
||||
// send
|
||||
|
||||
String[] idsArr = new String[ids.size()];
|
||||
|
||||
JSONObject requestObject = new JSONObject();
|
||||
|
||||
|
||||
try {
|
||||
requestObject.put("deviceUuid", UniqueDeviceUuid.getUniqueId(this));
|
||||
requestObject.put("fixes", jsonArray);
|
||||
} catch (JSONException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
|
||||
|
||||
if (BuildConfig.DEBUG) {
|
||||
ExLog.i(this, TAG, "sending gps fix json: " + requestObject.toString());
|
||||
ExLog.i(this, TAG, "url: " + prefs.getServerURL() + prefs.getServerGpsFixesPostPath());
|
||||
ExLog.i(this, TAG,
|
||||
"url: " + prefs.getServerURL() + prefs.getServerGpsFixesPostPath());
|
||||
}
|
||||
|
||||
if (host != null)
|
||||
{
|
||||
sendingAttempted = true;
|
||||
|
||||
JsonObjectOrStatusOnlyRequest request = new JsonObjectOrStatusOnlyRequest(host
|
||||
+ prefs.getServerGpsFixesPostPath(), requestObject, new FixSubmitListener(
|
||||
ids.toArray(idsArr)), new FixSubmitErrorListener(host,
|
||||
getTrackingServiceIsCurrentlyTracking(), failedHosts));
|
||||
|
||||
VolleyHelper.getInstance(this).addRequest(request);
|
||||
}
|
||||
else
|
||||
{
|
||||
|
||||
if (host != null) {
|
||||
if (currentlySending == true)
|
||||
{
|
||||
ExLog.w(this, TAG, "Warning, can't send fixes, currentlySending flag is set!");
|
||||
}
|
||||
else
|
||||
{
|
||||
currentlySending = true;
|
||||
sendingAttempted = true; // will be set to false in the
|
||||
// listeners
|
||||
JsonObjectOrStatusOnlyRequest request = new JsonObjectOrStatusOnlyRequest(host
|
||||
+ prefs.getServerGpsFixesPostPath(), requestObject,
|
||||
new FixSubmitListener(ids.toArray(idsArr)), new FixSubmitErrorListener(
|
||||
host, getTrackingServiceIsCurrentlyTracking(), failedHosts));
|
||||
|
||||
VolleyHelper.getInstance(this).addRequest(request);
|
||||
}
|
||||
} else {
|
||||
ExLog.w(this, TAG, "Warning, can't send fixes, host is null!");
|
||||
}
|
||||
|
||||
|
||||
} else {
|
||||
|
||||
if (serviceCanShutItselfDown())
|
||||
{
|
||||
|
||||
if (serviceCanShutItselfDown()) {
|
||||
if (BuildConfig.DEBUG) {
|
||||
ExLog.i(this, TAG, "Nothing to send or timeout occurred, Transmitting Service is stopping timer and terminating itself.");
|
||||
ExLog.i(this,
|
||||
TAG,
|
||||
"Nothing to send or timeout occurred, Transmitting Service is stopping timer and terminating itself.");
|
||||
}
|
||||
|
||||
|
||||
stopTimer();
|
||||
stopSelf();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* Get a count of ALL unsent GPS-fixes.
|
||||
*
|
||||
* This method is only interested in the GPS-fixes for the currently tracked event,
|
||||
* and needs to find out the id of that event first.
|
||||
* This method is only interested in the GPS-fixes for the currently tracked
|
||||
* event, and needs to find out the id of that event first.
|
||||
*
|
||||
* @return
|
||||
*/
|
||||
|
||||
private float getBatteryPercentage()
|
||||
{
|
||||
|
||||
private float getBatteryPercentage() {
|
||||
IntentFilter ifilter = new IntentFilter(Intent.ACTION_BATTERY_CHANGED);
|
||||
Intent batteryStatus = this.registerReceiver(null, ifilter);
|
||||
|
||||
|
||||
int level = batteryStatus.getIntExtra(BatteryManager.EXTRA_LEVEL, -1);
|
||||
int scale = batteryStatus.getIntExtra(BatteryManager.EXTRA_SCALE, -1);
|
||||
|
||||
float batteryPct = level / (float)scale;
|
||||
|
||||
float batteryPct = level / (float) scale;
|
||||
|
||||
if (BuildConfig.DEBUG) {
|
||||
ExLog.i(this, TAG, "Battery: " + (batteryPct * 100) + "%");
|
||||
}
|
||||
|
||||
|
||||
return batteryPct;
|
||||
}
|
||||
|
||||
private void deleteSynced(String[] fixIdStrings)
|
||||
{
|
||||
|
||||
private void deleteSynced(String[] fixIdStrings) {
|
||||
DatabaseHelper.getInstance().deleteGpsFixes(getBaseContext(), fixIdStrings);
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* checks if there is network connectivity
|
||||
*
|
||||
* @return connectivity check value
|
||||
*/
|
||||
private boolean isConnected() {
|
||||
ConnectivityManager connectivityManager = (ConnectivityManager) getSystemService(Context.CONNECTIVITY_SERVICE);
|
||||
NetworkInfo activeNetwork = connectivityManager.getActiveNetworkInfo();
|
||||
if (activeNetwork == null) {
|
||||
return false;
|
||||
}
|
||||
return activeNetwork.isConnected();
|
||||
}
|
||||
|
||||
private void enabledConnectivityReceiver()
|
||||
{
|
||||
ConnectivityChangedReceiver.enable(this);
|
||||
}
|
||||
|
||||
/**
|
||||
* Report API connectivity to listening activity
|
||||
* @param apiConnectivity
|
||||
*/
|
||||
private void reportApiConnectivity( APIConnectivity apiConnectivity )
|
||||
{
|
||||
if (apiConnectivityListener != null)
|
||||
{
|
||||
apiConnectivityListener.apiConnectivityUpdated( apiConnectivity );
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Report the number of currently unsent GPS-fixes
|
||||
* @param unsentGPSFixesCount
|
||||
*/
|
||||
private void reportUnsentGPSFixesCount( int unsentGPSFixesCount )
|
||||
{
|
||||
if (apiConnectivityListener != null)
|
||||
{
|
||||
apiConnectivityListener.setUnsentGPSFixesCount(unsentGPSFixesCount);
|
||||
}
|
||||
}
|
||||
|
||||
// might need this class in the future:
|
||||
//
|
||||
// private void markAsSynced(String[] fixIdStrings)
|
||||
// {
|
||||
// for (String idStr: fixIdStrings)
|
||||
// {
|
||||
// ContentValues updateValues = new ContentValues();
|
||||
// updateValues.put(SensorGps.GPS_SYNCED, 1);
|
||||
// Uri uri = ContentUris.withAppendedId(SensorGps.CONTENT_URI, Long.parseLong(idStr));
|
||||
// getContentResolver().update(uri, updateValues, null, null);
|
||||
// }
|
||||
// }
|
||||
|
||||
|
||||
|
||||
* checks if there is network connectivity
|
||||
*
|
||||
* @return connectivity check value
|
||||
*/
|
||||
private boolean isConnected() {
|
||||
ConnectivityManager connectivityManager = (ConnectivityManager) getSystemService(Context.CONNECTIVITY_SERVICE);
|
||||
NetworkInfo activeNetwork = connectivityManager.getActiveNetworkInfo();
|
||||
if (activeNetwork == null) {
|
||||
return false;
|
||||
}
|
||||
return activeNetwork.isConnected();
|
||||
}
|
||||
|
||||
private void enabledConnectivityReceiver() {
|
||||
ConnectivityChangedReceiver.enable(this);
|
||||
}
|
||||
|
||||
/**
|
||||
* Report API connectivity to listening activity
|
||||
*
|
||||
* @param apiConnectivity
|
||||
*/
|
||||
private void reportApiConnectivity(APIConnectivity apiConnectivity) {
|
||||
if (apiConnectivityListener != null) {
|
||||
apiConnectivityListener.apiConnectivityUpdated(apiConnectivity);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Report the number of currently unsent GPS-fixes
|
||||
*
|
||||
* @param unsentGPSFixesCount
|
||||
*/
|
||||
private void reportUnsentGPSFixesCount(int unsentGPSFixesCount) {
|
||||
if (apiConnectivityListener != null) {
|
||||
apiConnectivityListener.setUnsentGPSFixesCount(unsentGPSFixesCount);
|
||||
}
|
||||
}
|
||||
|
||||
// might need this class in the future:
|
||||
//
|
||||
// private void markAsSynced(String[] fixIdStrings)
|
||||
// {
|
||||
// for (String idStr: fixIdStrings)
|
||||
// {
|
||||
// ContentValues updateValues = new ContentValues();
|
||||
// updateValues.put(SensorGps.GPS_SYNCED, 1);
|
||||
// Uri uri = ContentUris.withAppendedId(SensorGps.CONTENT_URI,
|
||||
// Long.parseLong(idStr));
|
||||
// getContentResolver().update(uri, updateValues, null, null);
|
||||
// }
|
||||
// }
|
||||
|
||||
private class FixSubmitListener implements Listener<JSONObject> {
|
||||
|
||||
private String[] ids;
|
||||
private String[] ids;
|
||||
|
||||
public FixSubmitListener(String[] ids) {
|
||||
this.ids = ids;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void onResponse(JSONObject response) {
|
||||
deleteSynced(ids);
|
||||
markSuccessfulTransmission();
|
||||
//markAsSynced(ids);
|
||||
}
|
||||
}
|
||||
|
||||
private class FixSubmitErrorListener implements ErrorListener {
|
||||
|
||||
private String host;
|
||||
private List<String> failedHosts;
|
||||
private boolean currentlyTracking = false;
|
||||
|
||||
public FixSubmitErrorListener(String host, boolean currentlyTracking, List<String> failedHosts) {
|
||||
this.failedHosts = failedHosts;
|
||||
this.host = host;
|
||||
this.currentlyTracking = true;
|
||||
public FixSubmitListener(String[] ids) {
|
||||
this.ids = ids;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void onErrorResponse(VolleyError error) {
|
||||
markFailedTransmission();
|
||||
ExLog.e(TransmittingService.this, TAG, "Error while sending GPS fix " + error.getMessage());
|
||||
|
||||
if (!currentlyTracking)
|
||||
{
|
||||
if (failedHosts == null)
|
||||
{
|
||||
failedHosts = new ArrayList<String>();
|
||||
failedHosts.add(host);
|
||||
}
|
||||
|
||||
sendFixesToAPI(this.failedHosts);
|
||||
ExLog.i(TransmittingService.this, TAG, "Retrying resend step with this failed hosts list: " + failedHosts);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@Override
|
||||
public void onResponse(JSONObject response) {
|
||||
deleteSynced(ids);
|
||||
markSuccessfulTransmission();
|
||||
// markAsSynced(ids);
|
||||
}
|
||||
}
|
||||
|
||||
private class FixSubmitErrorListener implements ErrorListener {
|
||||
private String host;
|
||||
private List<String> failedHosts;
|
||||
private boolean currentlyTracking = false;
|
||||
|
||||
public FixSubmitErrorListener(String host, boolean currentlyTracking,
|
||||
List<String> failedHosts) {
|
||||
this.failedHosts = failedHosts;
|
||||
this.host = host;
|
||||
this.currentlyTracking = true;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void onErrorResponse(VolleyError error) {
|
||||
markFailedTransmission();
|
||||
ExLog.e(TransmittingService.this, TAG,
|
||||
"Error while sending GPS fix " + error.getMessage());
|
||||
|
||||
if (!currentlyTracking) {
|
||||
if (failedHosts == null) {
|
||||
failedHosts = new ArrayList<String>();
|
||||
failedHosts.add(host);
|
||||
}
|
||||
|
||||
sendFixesToAPI(this.failedHosts);
|
||||
ExLog.i(TransmittingService.this, TAG,
|
||||
"Retrying resend step with this failed hosts list: " + failedHosts);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
class Timer implements Runnable {
|
||||
public Thread t;
|
||||
public volatile boolean endExecution;
|
||||
|
||||
|
||||
@Override
|
||||
public void run() {
|
||||
while (!endExecution) {
|
||||
@@ -505,7 +493,7 @@ public class TransmittingService extends Service {
|
||||
} catch (InterruptedException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
|
||||
|
||||
timerFired();
|
||||
}
|
||||
reportApiConnectivity(APIConnectivity.noAttempt);
|
||||
@@ -518,50 +506,45 @@ public class TransmittingService extends Service {
|
||||
t.start();
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
public void stop() {
|
||||
endExecution = true;
|
||||
}
|
||||
}
|
||||
|
||||
public void registerAPIConnectivityListener( APIConnectivityListener listener )
|
||||
{
|
||||
|
||||
public void registerAPIConnectivityListener(APIConnectivityListener listener) {
|
||||
apiConnectivityListener = listener;
|
||||
}
|
||||
|
||||
public void unregisterAPIConnectivityListener()
|
||||
{
|
||||
|
||||
public void unregisterAPIConnectivityListener() {
|
||||
apiConnectivityListener = null;
|
||||
}
|
||||
|
||||
|
||||
public class TransmittingBinder extends Binder {
|
||||
public TransmittingService getService() {
|
||||
return TransmittingService.this;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
public enum APIConnectivity {
|
||||
notReachable (0),
|
||||
reachableTransmissionSuccess (1),
|
||||
reachableTransmissionError (2),
|
||||
noAttempt (4);
|
||||
|
||||
notReachable(0), reachableTransmissionSuccess(1), reachableTransmissionError(2), noAttempt(
|
||||
4);
|
||||
|
||||
private final int apiConnectivity;
|
||||
|
||||
APIConnectivity(int connectivity)
|
||||
{
|
||||
|
||||
APIConnectivity(int connectivity) {
|
||||
this.apiConnectivity = connectivity;
|
||||
}
|
||||
|
||||
public int toInt()
|
||||
{
|
||||
|
||||
public int toInt() {
|
||||
return this.apiConnectivity;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
public interface APIConnectivityListener {
|
||||
public void apiConnectivityUpdated( APIConnectivity apiConnectivity );
|
||||
public void setUnsentGPSFixesCount( int count );
|
||||
public void apiConnectivityUpdated(APIConnectivity apiConnectivity);
|
||||
|
||||
public void setUnsentGPSFixesCount(int count);
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
Reference in new issue
Block a user