msb-public
/
FairEmail
mirror of https://github.com/M66B/FairEmail.git
1
0
Code Issues Projects Releases Wiki Activity

Serialize operations for polling folders

Browse Source
pull/146/head
M66B 7 years ago
parent 72617d9860
commit 8d7916af04
1 changed files with 4 additions and 9 deletions
Show Stats Download Patch File Download Diff File

13
app/src/main/java/eu/faircode/email/ServiceSynchronize.java
Unescape View File

@ -888,6 +888,7 @@ public class ServiceSynchronize extends LifecycleService {
synchronizeFolders(account, istore, state); synchronizeFolders(account, istore, state);
// Open synchronizing folders // Open synchronizing folders
final ExecutorService pollExecutor = Executors.newSingleThreadExecutor(Helper.backgroundThreadFactory);
for (final EntityFolder folder : db.folder().getFolders(account.id)) { for (final EntityFolder folder : db.folder().getFolders(account.id)) {
if (folder.synchronize && !folder.poll && capIdle) { if (folder.synchronize && !folder.poll && capIdle) {
Log.i(Helper.TAG, account.name + " sync folder " + folder.name); Log.i(Helper.TAG, account.name + " sync folder " + folder.name);
@ -1095,7 +1096,7 @@ public class ServiceSynchronize extends LifecycleService {
private Observer<List<EntityOperation>> observer = new Observer<List<EntityOperation>>() { private Observer<List<EntityOperation>> observer = new Observer<List<EntityOperation>>() {
private List<Long> handling = new ArrayList<>(); private List<Long> handling = new ArrayList<>();
private final ExecutorService executor = Executors.newSingleThreadExecutor(Helper.backgroundThreadFactory); private final ExecutorService folderExecutor = Executors.newSingleThreadExecutor(Helper.backgroundThreadFactory);
private final PowerManager.WakeLock wlFolder = pm.newWakeLock( private final PowerManager.WakeLock wlFolder = pm.newWakeLock(
PowerManager.PARTIAL_WAKE_LOCK, BuildConfig.APPLICATION_ID + ":folder." + folder.id); PowerManager.PARTIAL_WAKE_LOCK, BuildConfig.APPLICATION_ID + ":folder." + folder.id);
@ -1112,7 +1113,7 @@ public class ServiceSynchronize extends LifecycleService {
if (handling.size() > 0 && process) { if (handling.size() > 0 && process) {
Log.i(Helper.TAG, folder.name + " operations=" + operations.size()); Log.i(Helper.TAG, folder.name + " operations=" + operations.size());
executor.submit(new Runnable() { (folder.poll ? pollExecutor : folderExecutor).submit(new Runnable() {
@Override @Override
public void run() { public void run() {
try { try {
@ -1120,13 +1121,7 @@ public class ServiceSynchronize extends LifecycleService {
Log.i(Helper.TAG, folder.name + " process"); Log.i(Helper.TAG, folder.name + " process");
// Get folder // Get folder
IMAPFolder ifolder = null; IMAPFolder ifolder = folders.get(folder); // null when polling
for (EntityFolder f : folders.keySet())
if (f.id.equals(folder.id)) {
ifolder = folders.get(f); // null when polling
break;
}
final boolean shouldClose = (ifolder == null); final boolean shouldClose = (ifolder == null);
try { try {

Write Preview
Loading…
Cancel
Save