Merge remote-tracking branch 'sbosley/120329_sb_astrid_sync_fixes'

astrid/plugin-src/com/todoroo/astrid/actfm/sync/ActFmSyncService.java

@@ -12,6 +12,7 @@ import java.util.HashSet;
 import java.util.LinkedList;
 import java.util.List;
 import java.util.Queue;
+import java.util.concurrent.atomic.AtomicInteger;
 
 import org.apache.http.entity.mime.MultipartEntity;
 import org.apache.http.entity.mime.content.ByteArrayBody;
@@ -22,6 +23,7 @@ import org.json.JSONObject;
 import android.content.ContentValues;
 import android.content.Context;
 import android.graphics.Bitmap;
+import android.os.ConditionVariable;
 import android.os.Handler;
 import android.os.Looper;
 import android.text.TextUtils;
@@ -112,8 +114,10 @@ public final class ActFmSyncService {
     }
 
     private final List<FailedPush> failedPushes = Collections.synchronizedList(new LinkedList<FailedPush>());
-    Thread pushRetryThread = null;
+    private Thread pushRetryThread = null;
-    Runnable pushRetryRunnable;
+    private Runnable pushRetryRunnable;
+    private final AtomicInteger taskPushThreads = new AtomicInteger(0);
+    private final ConditionVariable waitUntilEmpty = new ConditionVariable();
 
     public void initialize() {
         initializeRetryRunnable();
@@ -135,9 +139,17 @@ public final class ActFmSyncService {
                 new Thread(new Runnable() {
                     @Override
                     public void run() {
+                        waitUntilEmpty.close();
+                        taskPushThreads.incrementAndGet();
                         // sleep so metadata associated with task is saved
+                        try {
                             AndroidUtilities.sleepDeep(1000L);
                             pushTaskOnSave(model, setValues);
+                        } finally {
+                            if (taskPushThreads.decrementAndGet() == 0) {
+                                waitUntilEmpty.open();
+                            }
+                        }
                     }
                 }).start();
             }
@@ -235,6 +247,10 @@ public final class ActFmSyncService {
         }
     }
 
+    public void waitUntilEmpty() {
+        waitUntilEmpty.block();
+    }
+
     // --- data push methods
 
     /**

astrid/plugin-src/com/todoroo/astrid/actfm/sync/ActFmSyncV2Provider.java

@@ -106,9 +106,11 @@ public class ActFmSyncV2Provider extends SyncV2Provider {
     // --- synchronize active tasks
 
     @Override
-    public void synchronizeActiveTasks(boolean manual,
+    public void synchronizeActiveTasks(final boolean manual,
             final SyncResultCallback callback) {
 
+        new Thread(new Runnable() {
+            public void run() {
                 callback.started();
                 callback.incrementMax(100);
 
@@ -118,10 +120,13 @@ public class ActFmSyncV2Provider extends SyncV2Provider {
 
                 startTagFetcher(callback, finisher);
 
+                actFmSyncService.waitUntilEmpty();
                 startTaskFetcher(manual, callback, finisher);
 
                 callback.incrementProgress(50);
             }
+        }).start();
+    }
 
     /** fetch changes to tags */
     private void startTagFetcher(final SyncResultCallback callback,
@@ -238,15 +243,17 @@ public class ActFmSyncV2Provider extends SyncV2Provider {
     // --- synchronize list
 
     @Override
-    public void synchronizeList(Object list, boolean manual,
+    public void synchronizeList(Object list, final boolean manual,
             final SyncResultCallback callback) {
 
         if(!(list instanceof TagData))
             return;
 
-        TagData tagData = (TagData) list;
+        final TagData tagData = (TagData) list;
         final boolean noRemoteId = tagData.getValue(TagData.REMOTE_ID) == 0;
 
+        new Thread(new Runnable() {
+            public void run() {
                 callback.started();
                 callback.incrementMax(100);
 
@@ -255,12 +262,15 @@ public class ActFmSyncV2Provider extends SyncV2Provider {
                 fetchTagData(tagData, noRemoteId, manual, callback, finisher);
 
                 if(!noRemoteId) {
+                    actFmSyncService.waitUntilEmpty();
                     fetchTasksForTag(tagData, manual, callback, finisher);
                     fetchUpdatesForTag(tagData, manual, callback, finisher);
                 }
 
                 callback.incrementProgress(50);
             }
+        }).start();
+    }
 
     private void fetchTagData(final TagData tagData, final boolean noRemoteId,
             final boolean manual, final SyncResultCallback callback,