Spring/spring-session-data-geode
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Modify Thread count and Workload size to workaround Apache Geode concurrency problems.

Browse Source 
Any higher Thread count or Workload size greater than 4000 starts causeing Apache Geode availability/responsiveness (or liveness) issues!

These Apache Geode concurrency problems may be related to: https://issues.apache.org/jira/browse/GEODE-7663.
This commit is contained in:
John Blum
2020-01-24 00:47:05 -08:00
parent fc358985b7
commit a421e70904
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
spring-session-data-geode/src/integration-test/java/org/springframework/session/data/gemfire/MultiThreadedHighlyConcurrentClientServerHttpSessionAccessIntegrationTests.java
View File

@@ -39,12 +39,14 @@ import java.util.concurrent.Future;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicReference;
import org.apache.geode.cache.DataPolicy;
import org.apache.geode.cache.client.ClientRegionShortcut;
import org.junit.Before;
import org.junit.BeforeClass;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.apache.geode.cache.DataPolicy;
import org.apache.geode.cache.client.ClientRegionShortcut;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import org.springframework.context.annotation.Bean;
import org.springframework.data.gemfire.config.annotation.CacheServerApplication;
@@ -87,8 +89,10 @@ public class MultiThreadedHighlyConcurrentClientServerHttpSessionAccessIntegrati
private static final boolean SESSION_REFERENCE_CHECKING_ENABLED = false;
// TODO: Restore WORKLOAD_SIZE back to 10,000 once Apache Geode fixes its concurrency problems!
// NOTE: This issue may be related to: https://issues.apache.org/jira/browse/GEODE-7663
private static final int THREAD_COUNT = 180;
private static final int WORKLOAD_SIZE = 10000;
private static final int WORKLOAD_SIZE = 2000;
private static final String GEMFIRE_LOG_LEVEL = "error";
@@ -217,7 +221,6 @@ public class MultiThreadedHighlyConcurrentClientServerHttpSessionAccessIntegrati
};
}
@SuppressWarnings("all")
private Callable<Integer> newRemoveSessionAttributeTask() {
return () -> {
@@ -370,6 +373,7 @@ public class MultiThreadedHighlyConcurrentClientServerHttpSessionAccessIntegrati
}
}
@SuppressWarnings("rawtypes")
static class SpyingDataSerializableSessionSerializer
extends AbstractDataSerializableSessionSerializer<GemFireSession> {