mirror of
https://github.com/hapifhir/hapi-fhir.git
synced 2025-02-28 17:19:24 +00:00
Fix intermittent test failure
This commit is contained in:
parent
6dc2dc1d6f
commit
b75226914d
@ -1,8 +1,11 @@
|
|||||||
package ca.uhn.fhir.jpa.provider.r4;
|
package ca.uhn.fhir.jpa.provider.r4;
|
||||||
|
|
||||||
|
import ca.uhn.fhir.jpa.config.TestR4Config;
|
||||||
|
import ca.uhn.fhir.jpa.dao.DaoConfig;
|
||||||
import ca.uhn.fhir.jpa.search.SearchCoordinatorSvcImpl;
|
import ca.uhn.fhir.jpa.search.SearchCoordinatorSvcImpl;
|
||||||
import ca.uhn.fhir.rest.api.SummaryEnum;
|
import ca.uhn.fhir.rest.api.SummaryEnum;
|
||||||
import ca.uhn.fhir.util.TestUtil;
|
import ca.uhn.fhir.util.TestUtil;
|
||||||
|
import com.google.common.collect.Lists;
|
||||||
import org.hl7.fhir.r4.model.Bundle;
|
import org.hl7.fhir.r4.model.Bundle;
|
||||||
import org.hl7.fhir.r4.model.Narrative;
|
import org.hl7.fhir.r4.model.Narrative;
|
||||||
import org.hl7.fhir.r4.model.Patient;
|
import org.hl7.fhir.r4.model.Patient;
|
||||||
@ -11,6 +14,8 @@ import org.junit.AfterClass;
|
|||||||
import org.junit.Test;
|
import org.junit.Test;
|
||||||
import org.springframework.test.util.AopTestUtils;
|
import org.springframework.test.util.AopTestUtils;
|
||||||
|
|
||||||
|
import java.util.ArrayList;
|
||||||
|
|
||||||
import static org.junit.Assert.assertEquals;
|
import static org.junit.Assert.assertEquals;
|
||||||
|
|
||||||
@SuppressWarnings("Duplicates")
|
@SuppressWarnings("Duplicates")
|
||||||
@ -26,6 +31,7 @@ public class ResourceProviderSummaryModeR4Test extends BaseResourceProviderR4Tes
|
|||||||
myDaoConfig.setCountSearchResultsUpTo(null);
|
myDaoConfig.setCountSearchResultsUpTo(null);
|
||||||
mySearchCoordinatorSvcRaw.setLoadingThrottleForUnitTests(null);
|
mySearchCoordinatorSvcRaw.setLoadingThrottleForUnitTests(null);
|
||||||
mySearchCoordinatorSvcRaw.setSyncSizeForUnitTests(SearchCoordinatorSvcImpl.DEFAULT_SYNC_SIZE);
|
mySearchCoordinatorSvcRaw.setSyncSizeForUnitTests(SearchCoordinatorSvcImpl.DEFAULT_SYNC_SIZE);
|
||||||
|
myDaoConfig.setSearchPreFetchThresholds(new DaoConfig().getSearchPreFetchThresholds());
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
@ -34,9 +40,11 @@ public class ResourceProviderSummaryModeR4Test extends BaseResourceProviderR4Tes
|
|||||||
myDaoConfig.setCountSearchResultsUpTo(5);
|
myDaoConfig.setCountSearchResultsUpTo(5);
|
||||||
|
|
||||||
mySearchCoordinatorSvcRaw = AopTestUtils.getTargetObject(mySearchCoordinatorSvc);
|
mySearchCoordinatorSvcRaw = AopTestUtils.getTargetObject(mySearchCoordinatorSvc);
|
||||||
mySearchCoordinatorSvcRaw.setLoadingThrottleForUnitTests(250);
|
mySearchCoordinatorSvcRaw.setLoadingThrottleForUnitTests(50);
|
||||||
mySearchCoordinatorSvcRaw.setSyncSizeForUnitTests(5);
|
mySearchCoordinatorSvcRaw.setSyncSizeForUnitTests(5);
|
||||||
|
|
||||||
|
myDaoConfig.setSearchPreFetchThresholds(Lists.newArrayList(20, 50, -1));
|
||||||
|
|
||||||
runInTransaction(() -> {
|
runInTransaction(() -> {
|
||||||
for (int i = 0; i < 104; i++) {
|
for (int i = 0; i < 104; i++) {
|
||||||
Patient p = new Patient();
|
Patient p = new Patient();
|
||||||
|
Loading…
x
Reference in New Issue
Block a user