PawletOS/lineageos_updater
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Perform some database operations in separate threads

Browse Source 
These operations shouldn't be frequent enough to require explicit
synchronization.
This commit is contained in:
Gabriele M
2017-07-04 19:05:04 +02:00
parent fe18add111
commit c4c5a72c75
1 changed files with 14 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/org/lineageos/updater/controller/UpdaterController.java
View File

@@ -113,7 +113,7 @@ public class UpdaterController implements UpdaterControllerInt {
@Override @Override
public void onResponse(int statusCode, String url, DownloadClient.Headers headers) { public void onResponse(int statusCode, String url, DownloadClient.Headers headers) {
UpdateDownload update = mDownloads.get(downloadId).mUpdate; final UpdateDownload update = mDownloads.get(downloadId).mUpdate;
String contentLenght = headers.get("Content-Length"); String contentLenght = headers.get("Content-Length");
if (contentLenght != null) { if (contentLenght != null) {
try { try {
@@ -125,7 +125,12 @@ public class UpdaterController implements UpdaterControllerInt {
} }
update.setStatus(UpdateStatus.DOWNLOADING); update.setStatus(UpdateStatus.DOWNLOADING);
update.setPersistentStatus(UpdateStatus.Persistent.INCOMPLETE); update.setPersistentStatus(UpdateStatus.Persistent.INCOMPLETE);
mUpdatesDbHelper.addUpdateWithOnConflict(update); new Thread(new Runnable() {
@Override
public void run() {
mUpdatesDbHelper.addUpdateWithOnConflict(update);
}
}).start();
notifyUpdateChange(downloadId); notifyUpdateChange(downloadId);
} }
@@ -242,7 +247,7 @@ public class UpdaterController implements UpdaterControllerInt {
return addUpdate(update, false); return addUpdate(update, false);
} }
private boolean addUpdate(UpdateDownload update, boolean local) { private boolean addUpdate(final UpdateDownload update, boolean local) {
Log.d(TAG, "Adding download: " + update.getDownloadId()); Log.d(TAG, "Adding download: " + update.getDownloadId());
if (mDownloads.containsKey(update.getDownloadId())) { if (mDownloads.containsKey(update.getDownloadId())) {
Log.e(TAG, "Download (" + update.getDownloadId() + ") already added"); Log.e(TAG, "Download (" + update.getDownloadId() + ") already added");
@@ -250,7 +255,12 @@ public class UpdaterController implements UpdaterControllerInt {
} }
if (!fixUpdateStatus(update) && local) { if (!fixUpdateStatus(update) && local) {
update.setPersistentStatus(UpdateStatus.Persistent.UNKNOWN); update.setPersistentStatus(UpdateStatus.Persistent.UNKNOWN);
mUpdatesDbHelper.removeUpdate(update.getDownloadId()); new Thread(new Runnable() {
@Override
public void run() {
mUpdatesDbHelper.removeUpdate(update.getDownloadId());
}
}).start();
Log.d(TAG, update.getDownloadId() + " had an invalid status and is local"); Log.d(TAG, update.getDownloadId() + " had an invalid status and is local");
return false; return false;
} }