Add test case for multiple change trackers

Author: hideki

src/androidTest/java/com/couchbase/lite/replicator/ManualReplicationTest.java

@@ -0,0 +1,116 @@
+package com.couchbase.lite.replicator;
+
+import com.couchbase.lite.LiteTestCaseWithDB;
+import com.couchbase.lite.mockserver.MockChangesFeedNoResponse;
+import com.couchbase.lite.mockserver.MockCheckpointPut;
+import com.couchbase.lite.mockserver.MockDispatcher;
+import com.couchbase.lite.mockserver.MockHelper;
+import com.couchbase.lite.util.Log;
+import com.squareup.okhttp.mockwebserver.MockWebServer;
+
+import java.util.Set;
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
+
+public class ManualReplicationTest extends LiteTestCaseWithDB {
+
+    // https://github.com/couchbase/couchbase-lite-java-core/issues/1116
+    // Multiple ChangeTrackers are started (Scenario 3)
+    //
+    // This test is not solid test.  I set this as manual test. Not run on Jenkins.
+    public void manualTestMultipleChangeTrackerScenario3() throws Exception {
+        Log.d(Log.TAG, "testMultipleChangeTrackerScenario3");
+
+        Replication pullReplication = null;
+        // create mock server
+        MockWebServer server = new MockWebServer();
+        try {
+            MockDispatcher dispatcher = new MockDispatcher();
+            dispatcher.setServerType(MockDispatcher.ServerType.SYNC_GW);
+            server.setDispatcher(dispatcher);
+            server.play();
+
+            // checkpoint PUT or GET response (sticky)
+            MockCheckpointPut mockCheckpointPut = new MockCheckpointPut();
+            mockCheckpointPut.setSticky(true);
+            mockCheckpointPut.setDelayMs(10 * 1000); // 10sec
+            dispatcher.enqueueResponse(MockHelper.PATH_REGEX_CHECKPOINT, mockCheckpointPut);
+
+            // long poll changes feed no response balock 5 min
+            MockChangesFeedNoResponse mockChangesFeedNoResponse = new MockChangesFeedNoResponse();
+            mockChangesFeedNoResponse.setSticky(true);
+            mockChangesFeedNoResponse.setDelayMs(300 * 1000); // 60 sec
+            dispatcher.enqueueResponse(MockHelper.PATH_REGEX_CHANGES, mockChangesFeedNoResponse);
+
+            // create and start replication
+            pullReplication = database.createPullReplication(server.getUrl("/db"));
+            pullReplication.setContinuous(true);
+            pullReplication.start();
+            Log.d(Log.TAG, "Started pullReplication: %s", pullReplication);
+
+            // offline
+            putReplicationOffline(pullReplication);
+
+            // online
+            putReplicationOnline(pullReplication);
+
+            // wait
+            try {
+                Thread.sleep(30 * 1000);
+            } catch (Exception e) {
+            }
+
+            // all threads which are associated with replicators should be terminated.
+            int numChangeTracker = 0;
+            Set<Thread> threadSet = Thread.getAllStackTraces().keySet();
+            for (Thread t : threadSet) {
+                if (t.isAlive()) {
+                    if (t.getName().indexOf("ChangeTracker-") != -1) {
+                        numChangeTracker++;
+                    }
+                }
+            }
+            assertEquals(1, numChangeTracker);
+
+        } finally {
+            stopReplication(pullReplication);
+            server.shutdown();
+        }
+    }
+
+    private void putReplicationOffline(Replication replication) throws InterruptedException {
+        Log.d(Log.TAG, "putReplicationOffline: %s", replication);
+
+        // this was a useless test, the replication wasn't even started
+        final CountDownLatch wentOffline = new CountDownLatch(1);
+        Replication.ChangeListener changeListener = new ReplicationOfflineObserver(wentOffline);
+        replication.addChangeListener(changeListener);
+
+        replication.goOffline();
+        boolean succeeded = wentOffline.await(30, TimeUnit.SECONDS);
+        assertTrue(succeeded);
+
+        replication.removeChangeListener(changeListener);
+
+        Log.d(Log.TAG, "/putReplicationOffline: %s", replication);
+    }
+
+    private void putReplicationOnline(Replication replication) throws InterruptedException {
+
+        Log.d(Log.TAG, "putReplicationOnline: %s", replication);
+
+        // this was a useless test, the replication wasn't even started
+        final CountDownLatch wentOnline = new CountDownLatch(1);
+        Replication.ChangeListener changeListener = new ReplicationActiveObserver(wentOnline);
+        replication.addChangeListener(changeListener);
+
+        replication.goOnline();
+
+        boolean succeeded = wentOnline.await(30, TimeUnit.SECONDS);
+        assertTrue(succeeded);
+
+        replication.removeChangeListener(changeListener);
+
+        Log.d(Log.TAG, "/putReplicationOnline: %s", replication);
+    }
+}