@@ -873,7 +873,6 @@ public void changed(LiveQuery.ChangeEvent event) {
873873 public void testContinuousPushRetryBehavior () throws Exception {
874874
875875 RemoteRequestRetry .RETRY_DELAY_MS = 5 ; // speed up test execution (inner loop retry delay)
876-
877876 ReplicationInternal .RETRY_DELAY_SECONDS = 1 ; // speed up test execution (outer loop retry delay)
878877 ReplicationInternal .MAX_RETRIES = 3 ; // spped up test execution (outer loop retry count)
879878
@@ -3325,10 +3324,10 @@ public void testMockPullBulkDocsSyncGw() throws Exception {
33253324 mockPullBulkDocs (MockDispatcher .ServerType .SYNC_GW );
33263325 }
33273326
3328-
33293327 public void mockPullBulkDocs (MockDispatcher .ServerType serverType ) throws Exception {
33303328
33313329 // set INBOX_CAPACITY to a smaller value so that processing times don't skew the test
3330+ int previous = ReplicationInternal .INBOX_CAPACITY ;
33323331 ReplicationInternal .INBOX_CAPACITY = 10 ;
33333332
33343333 // serve 25 mock docs
@@ -3358,7 +3357,6 @@ public void mockPullBulkDocs(MockDispatcher.ServerType serverType) throws Except
33583357 for (MockDocumentGet .MockDocument mockDocument : mockDocs ) {
33593358 MockDocumentGet mockDocumentGet = new MockDocumentGet (mockDocument );
33603359 dispatcher .enqueueResponse (mockDocument .getDocPathRegex (), mockDocumentGet .generateMockResponse ());
3361-
33623360 }
33633361
33643362 // _bulk_get response
@@ -3399,19 +3397,17 @@ public void mockPullBulkDocs(MockDispatcher.ServerType serverType) throws Except
33993397 Log .w (TAG , "docs.size() %d != ReplicationInternal.INBOX_CAPACITY %d" , docs .size (), ReplicationInternal .INBOX_CAPACITY );
34003398 }
34013399 }
3402-
34033400 }
34043401
34053402 // should not be any requests for individual docs
34063403 for (MockDocumentGet .MockDocument mockDocument : mockDocs ) {
3407- MockDocumentGet mockDocumentGet = new MockDocumentGet (mockDocument );
34083404 BlockingQueue <RecordedRequest > requestsForDoc = dispatcher .getRequestQueueSnapshot (mockDocument .getDocPathRegex ());
34093405 assertTrue (requestsForDoc == null || requestsForDoc .isEmpty ());
34103406 }
34113407
34123408 server .shutdown ();
34133409
3414-
3410+ ReplicationInternal . INBOX_CAPACITY = previous ;
34153411 }
34163412
34173413 /**
@@ -3688,6 +3684,7 @@ public void changed(Replication.ChangeEvent event) {
36883684 public void testContinuousPushReplicationGoesIdleTooSoon () throws Exception {
36893685
36903686 // smaller batch size so there are multiple requests to _bulk_docs
3687+ int previous = ReplicationInternal .INBOX_CAPACITY ;
36913688 ReplicationInternal .INBOX_CAPACITY = 5 ;
36923689 int numDocs = ReplicationInternal .INBOX_CAPACITY * 5 ;
36933690
@@ -3780,6 +3777,8 @@ public void changed(Replication.ChangeEvent event) {
37803777 waitForPutCheckpointRequestWithSeq (dispatcher , (int ) database .getLastSequenceNumber ());
37813778
37823779 server .shutdown ();
3780+
3781+ ReplicationInternal .INBOX_CAPACITY = previous ;
37833782 }
37843783
37853784 /**
@@ -3943,7 +3942,6 @@ public void testCheckSessionAndCheckpointWhenRetryingReplication() throws Except
39433942 */
39443943 public void testStopReplicatorWhenRetryingReplicationWithPermanentError () throws Exception {
39453944 RemoteRequestRetry .RETRY_DELAY_MS = 5 ; // speed up test execution (inner loop retry delay)
3946-
39473945 ReplicationInternal .RETRY_DELAY_SECONDS = 1 ; // speed up test execution (outer loop retry delay)
39483946 ReplicationInternal .MAX_RETRIES = 3 ; // speed up test execution (outer loop retry count)
39493947
0 commit comments