[geode] branch develop updated (53f1e1a -> f6ebc63)
This is an automated email from the ASF dual-hosted git repository. onichols pushed a change to branch develop in repository https://gitbox.apache.org/repos/asf/geode.git. from 53f1e1a GEODE-7852: Adding a SocketFactory configuration for client Pools (#4830) add f6ebc63 Ignore ClientSNIAcceptanceTest on windows (#4837) No new revisions were added by this update. Summary of changes: .../java/org/apache/geode/client/ClientSNIAcceptanceTest.java | 8 1 file changed, 8 insertions(+)
[geode] 01/01: GEODE-6008 work in progress
This is an automated email from the ASF dual-hosted git repository.
bschuchardt pushed a commit to branch feature/GEODE-6008
in repository https://gitbox.apache.org/repos/asf/geode.git
commit 071c4e4c98144741e30adcee19d72bec2cdc2c34
Author: Bruce Schuchardt
AuthorDate: Fri Mar 20 15:56:22 2020 -0700
GEODE-6008 work in progress
---
...tServerHostNameVerificationDistributedTest.java | 2 +
.../internal/tcp/TCPConduitBareBonesDUnitTest.java | 76 ++
.../apache/geode/distributed/internal/DMStats.java | 2 +
.../distributed/internal/DistributionStats.java| 9 +++
.../internal/LonerDistributionManager.java | 5 ++
.../org/apache/geode/internal/tcp/Connection.java | 29 +++--
.../org/apache/geode/internal/tcp/TCPConduit.java | 4 +-
7 files changed, 118 insertions(+), 9 deletions(-)
diff --git
a/geode-core/src/distributedTest/java/org/apache/geode/cache/client/internal/ClientServerHostNameVerificationDistributedTest.java
b/geode-core/src/distributedTest/java/org/apache/geode/cache/client/internal/ClientServerHostNameVerificationDistributedTest.java
index 8f1db5f..8ce2b34 100644
---
a/geode-core/src/distributedTest/java/org/apache/geode/cache/client/internal/ClientServerHostNameVerificationDistributedTest.java
+++
b/geode-core/src/distributedTest/java/org/apache/geode/cache/client/internal/ClientServerHostNameVerificationDistributedTest.java
@@ -39,6 +39,7 @@ import
org.apache.geode.cache.client.NoAvailableServersException;
import org.apache.geode.cache.ssl.CertStores;
import org.apache.geode.cache.ssl.CertificateBuilder;
import org.apache.geode.cache.ssl.CertificateMaterial;
+import org.apache.geode.internal.inet.LocalHostUtil;
import org.apache.geode.internal.net.SocketCreatorFactory;
import org.apache.geode.test.dunit.IgnoredException;
import org.apache.geode.test.dunit.rules.ClusterStartupRule;
@@ -162,6 +163,7 @@ public class
ClientServerHostNameVerificationDistributedTest {
.sanDnsName(InetAddress.getLoopbackAddress().getHostName())
.sanDnsName(InetAddress.getLocalHost().getHostName())
.sanDnsName(InetAddress.getLocalHost().getCanonicalHostName())
+.sanIpAddress(LocalHostUtil.getLocalHost())
.sanIpAddress(InetAddress.getLocalHost())
.generate();
diff --git
a/geode-core/src/distributedTest/java/org/apache/geode/internal/tcp/TCPConduitBareBonesDUnitTest.java
b/geode-core/src/distributedTest/java/org/apache/geode/internal/tcp/TCPConduitBareBonesDUnitTest.java
new file mode 100644
index 000..77eb02e
--- /dev/null
+++
b/geode-core/src/distributedTest/java/org/apache/geode/internal/tcp/TCPConduitBareBonesDUnitTest.java
@@ -0,0 +1,76 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
contributor license
+ * agreements. See the NOTICE file distributed with this work for additional
information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache
License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the
License. You may obtain a
+ * copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
KIND, either express
+ * or implied. See the License for the specific language governing permissions
and limitations under
+ * the License.
+ */
+package org.apache.geode.internal.tcp;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+import java.util.Properties;
+
+import org.junit.Rule;
+import org.junit.Test;
+
+import org.apache.geode.distributed.ConfigurationProperties;
+import org.apache.geode.distributed.internal.DistributionConfig;
+import org.apache.geode.distributed.internal.DistributionConfigImpl;
+import org.apache.geode.distributed.internal.DistributionImpl;
+import org.apache.geode.distributed.internal.InternalDistributedSystem;
+import
org.apache.geode.distributed.internal.membership.InternalDistributedMember;
+import org.apache.geode.test.dunit.DistributedTestUtils;
+import org.apache.geode.test.dunit.rules.DistributedRule;
+
+public class TCPConduitBareBonesDUnitTest {
+
+ @Rule
+ public DistributedRule distributedRule = new DistributedRule(0);
+
+ @Test
+ public void testShortTermSharedConnections() throws Exception {
+// create and close many shared, ordered connections. Also see
CloseConnectionTest,
+// which ensures that the outgoing socket in a shared connection is
properly closed
+Properties properties = new Properties();
+properties.put(ConfigurationProperties.LOG_LEVEL, "fine");
+properties.put(ConfigurationProperties.LOCATORS,
DistributedTestUtils.getLocators());
+DistributionConfig configuration = new DistributionConfigImpl(properties);
+InternalDistributedSystem distributedSystem =
+(InternalDistributedSystem)
[geode] branch feature/GEODE-6008 created (now 071c4e4)
This is an automated email from the ASF dual-hosted git repository. bschuchardt pushed a change to branch feature/GEODE-6008 in repository https://gitbox.apache.org/repos/asf/geode.git. at 071c4e4 GEODE-6008 work in progress This branch includes the following new commits: new 071c4e4 GEODE-6008 work in progress The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[geode] branch develop updated (39a8eaa -> 53f1e1a)
This is an automated email from the ASF dual-hosted git repository. upthewaterspout pushed a change to branch develop in repository https://gitbox.apache.org/repos/asf/geode.git. from 39a8eaa GEODE-7886 Update strings tests to cover sad as well as happy paths (#4821) add 53f1e1a GEODE-7852: Adding a SocketFactory configuration for client Pools (#4830) No new revisions were added by this update. Summary of changes: geode-assembly/build.gradle| 10 ++ .../geode/client/ClientSNIAcceptanceTest.java | 91 +++ .../org/apache/geode/client/docker-compose.yml | 43 +++ .../geode/client/geode-config/gemfire.properties | 18 +++ .../client/geode-config/gfsecurity.properties | 27 + .../geode/client/geode-config/locator-keystore.jks | Bin 0 -> 2028 bytes .../geode/client/geode-config/server-keystore.jks | Bin 0 -> 2025 bytes .../geode/client/geode-config/truststore.jks | Bin 0 -> 6023 bytes .../resources/org/apache/geode/client/haproxy.cfg | 40 +++ .../org/apache/geode/client/scripts/forever| 20 .../apache/geode/client/scripts/geode-starter.gfsh | 23 .../integrationTest/resources/assembly_content.txt | 6 + .../geode/cache/client/SocketFactoryDUnitTest.java | 128 + .../internal/LocatorLoadBalancingDUnitTest.java| 4 +- .../geode/cache30/CacheXmlGeode10DUnitTest.java| 38 ++ .../AutoConnectionSourceImplJUnitTest.java | 15 ++- .../client/internal/QueueManagerJUnitTest.java | 6 + .../geode/distributed/LocatorIntegrationTest.java | 4 +- .../internal/membership/MembershipJUnitTest.java | 4 +- .../membership/gms/MembershipOnlyTest.java | 3 +- .../tcpserver/TCPClientSSLIntegrationTest.java | 3 +- .../internal/tcpserver/TCPServerSSLJUnitTest.java | 3 +- .../internal/net/SSLSocketIntegrationTest.java | 3 +- .../internal/DistributionLocatorConfigImpl.java| 4 +- .../geode/cache/client/ClientCacheFactory.java | 26 + .../java/org/apache/geode/cache/client/Pool.java | 7 ++ .../org/apache/geode/cache/client/PoolFactory.java | 23 .../apache/geode/cache/client/SocketFactory.java | 58 ++ .../client/internal/AutoConnectionSourceImpl.java | 7 +- .../cache/client/internal/ConnectionConnector.java | 11 +- .../client/internal/ConnectionFactoryImpl.java | 3 +- .../cache/client/internal/ConnectionImpl.java | 6 +- .../geode/cache/client/internal/PoolImpl.java | 16 ++- .../cache/client/proxy/ProxySocketFactories.java | 32 ++ .../geode/cache/client/proxy/SniProxySocket.java | 41 +++ .../geode/cache/client/proxy/SniSocketFactory.java | 43 +++ .../apache/geode/distributed/LocatorLauncher.java | 4 +- .../distributed/internal/DistributionImpl.java | 4 +- .../org/apache/geode/internal/SystemAdmin.java | 4 +- .../geode/internal/cache/PoolFactoryImpl.java | 19 ++- .../cache/tier/sockets/CacheClientUpdater.java | 11 +- .../geode/internal/cache/xmlcache/CacheXml.java| 1 + .../internal/cache/xmlcache/CacheXmlGenerator.java | 5 + .../internal/cache/xmlcache/CacheXmlParser.java| 22 .../internal/net/SCAdvancedSocketCreator.java | 20 ++-- .../apache/geode/internal/net/SocketCreator.java | 17 ++- .../internal/JmxManagerLocatorRequest.java | 4 +- .../internal/api/GeodeConnectionConfig.java| 4 +- .../utils/ClusterConfigurationStatusRetriever.java | 4 +- .../geode.apache.org/schema/cache/cache-1.0.xsd| 3 + .../sanctioned-geode-core-serializables.txt| 2 +- .../client/internal/ConnectionConnectorTest.java | 9 +- .../tier/sockets/CacheClientUpdaterJUnitTest.java | 6 +- .../gms/locator/GMSLocatorIntegrationTest.java | 3 +- .../locator/GMSLocatorRecoveryIntegrationTest.java | 6 +- .../gms/locator/MembershipLocatorImpl.java | 3 +- .../membership/gms/membership/GMSJoinLeave.java| 2 +- .../TcpServerProductVersionDUnitTest.java | 3 +- .../internal/tcpserver/AdvancedSocketCreator.java | 5 + .../tcpserver/AdvancedSocketCreatorImpl.java | 21 ++-- .../internal/tcpserver/ClientSocketCreator.java| 7 +- .../tcpserver/ClientSocketCreatorImpl.java | 9 +- .../internal/tcpserver/ClusterSocketCreator.java | 3 +- .../tcpserver/ClusterSocketCreatorImpl.java| 5 +- .../distributed/internal/tcpserver/TcpClient.java | 8 +- .../internal/tcpserver/TcpSocketCreatorImpl.java | 10 +- .../internal/tcpserver/TcpSocketFactory.java | 29 + .../internal/tcpserver/TcpServerJUnitTest.java | 2 +- .../internal/locator/wan/LocatorDiscovery.java | 4 +- .../locator/wan/LocatorMembershipListenerImpl.java | 4 +- .../cache/wan/AbstractRemoteGatewaySender.java | 4 +- 71 files changed, 944 insertions(+), 89 deletions(-) create mode 100644
[geode] branch develop updated (2d2a3f8 -> 39a8eaa)
This is an automated email from the ASF dual-hosted git repository.
jensdeppe pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/geode.git.
from 2d2a3f8 GEODE-7884: server hangs due to IllegalStateException (#4822)
add 39a8eaa GEODE-7886 Update strings tests to cover sad as well as happy
paths (#4821)
No new revisions were added by this update.
Summary of changes:
.../apache/geode/redis/StringsIntegrationTest.java | 744 +
.../org/apache/geode/redis/internal/Coder.java | 13 +-
.../apache/geode/redis/internal/KeyRegistrar.java | 2 +-
.../geode/redis/internal/RedisConstants.java | 2 +
.../internal/executor/string/DecrExecutor.java | 81 ++-
.../internal/executor/string/GetRangeExecutor.java | 42 +-
.../internal/executor/string/GetSetExecutor.java | 39 +-
.../internal/executor/string/IncrExecutor.java | 96 +--
.../internal/executor/string/MSetExecutor.java | 20 +-
.../internal/executor/string/MSetNXExecutor.java | 7 +-
.../internal/executor/string/SetNXExecutor.java| 5 +-
.../internal/executor/string/StringExecutor.java | 10 +
.../internal/executor/string/StrlenExecutor.java | 8 +-
...ExecutorTest.java => DelExecutorJUnitTest.java} | 5 +-
.../executor/string/GetRangeExecutorJUnitTest.java | 147
.../executor/string/GetSetExecutorJUnitTest.java | 125
...xecutorTest.java => IncrExecutorJUnitTest.java} | 64 +-
.../string/StringMGetExecutorJUnitTest.java| 88 +++
.../string/StringMSetExecutorJUnitTest.java| 91 +++
...cutorTest.java => StrlenExecutorJUnitTest.java} | 33 +-
20 files changed, 1348 insertions(+), 274 deletions(-)
copy
geode-redis/src/test/java/org/apache/geode/redis/internal/executor/string/{DelExecutorTest.java
=> DelExecutorJUnitTest.java} (96%)
create mode 100644
geode-redis/src/test/java/org/apache/geode/redis/internal/executor/string/GetRangeExecutorJUnitTest.java
create mode 100644
geode-redis/src/test/java/org/apache/geode/redis/internal/executor/string/GetSetExecutorJUnitTest.java
copy
geode-redis/src/test/java/org/apache/geode/redis/internal/executor/string/{DelExecutorTest.java
=> IncrExecutorJUnitTest.java} (50%)
create mode 100644
geode-redis/src/test/java/org/apache/geode/redis/internal/executor/string/StringMGetExecutorJUnitTest.java
create mode 100644
geode-redis/src/test/java/org/apache/geode/redis/internal/executor/string/StringMSetExecutorJUnitTest.java
rename
geode-redis/src/test/java/org/apache/geode/redis/internal/executor/string/{DelExecutorTest.java
=> StrlenExecutorJUnitTest.java} (67%)
[geode] branch release/1.12.0 updated: GEODE-7863: Reduce ServerCQImpl Contention (#4798)
This is an automated email from the ASF dual-hosted git repository.
echobravo pushed a commit to branch release/1.12.0
in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/release/1.12.0 by this push:
new 4ede81a GEODE-7863: Reduce ServerCQImpl Contention (#4798)
4ede81a is described below
commit 4ede81abb2393bddbfb0e297cfc7bdfa3fee800b
Author: Juan José Ramos
AuthorDate: Mon Mar 16 10:33:52 2020 +
GEODE-7863: Reduce ServerCQImpl Contention (#4798)
We don't need to lock the entire internal cache for Partitioned
regions so the implementation is now split by region type, this will
us to improve/change them independently in the future.
- Removed redundant checks.
- Keep current behavior for Replicate Regions.
- Use ConcurrentMap instead of locking the entire internal cache on
every operation for Partition Regions.
- Keep the lock on ServerCQImpl instance only while executing the
query and leave stats operations outside of the synchronized block.
(cherry picked from commit 9e3c473e9cf6d72126d0e84319b1192a5e2b6fdb)
---
.../cache/query/internal/cq/CqServiceProvider.java | 2 +-
.../geode/cache/query/internal/cq/ServerCQ.java| 6 +
.../geode/cache/query/cq/internal/CqQueryImpl.java | 2 -
.../cache/query/cq/internal/CqServiceImpl.java | 38 ++---
.../cache/query/cq/internal/ServerCQImpl.java | 176 +
.../query/cq/internal/ServerCQResultsCache.java| 48 ++
.../cq/internal/ServerCQResultsCacheNoOpImpl.java | 68
.../ServerCQResultsCachePartitionRegionImpl.java | 133
.../ServerCQResultsCacheReplicateRegionImpl.java | 176 +
.../query/cq/internal/command/ExecuteCQ61.java | 2 +-
.../cache/query/cq/internal/ServerCQImplTest.java | 4 +-
11 files changed, 493 insertions(+), 162 deletions(-)
diff --git
a/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/CqServiceProvider.java
b/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/CqServiceProvider.java
index 28ecabb..e61c27b 100644
---
a/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/CqServiceProvider.java
+++
b/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/CqServiceProvider.java
@@ -36,7 +36,7 @@ public class CqServiceProvider {
*/
@MutableForTesting
public static boolean MAINTAIN_KEYS = Boolean
- .valueOf(System.getProperty(GeodeGlossary.GEMFIRE_PREFIX +
"cq.MAINTAIN_KEYS", "true"));
+ .parseBoolean(System.getProperty(GeodeGlossary.GEMFIRE_PREFIX +
"cq.MAINTAIN_KEYS", "true"));
/**
* A debug flag used for testing vMotion during CQ registration
diff --git
a/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/ServerCQ.java
b/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/ServerCQ.java
index c36cd4b..08bfba3 100644
---
a/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/ServerCQ.java
+++
b/geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/ServerCQ.java
@@ -66,6 +66,12 @@ public interface ServerCQ extends InternalCqQuery {
void setCqResultsCacheInitialized();
/**
+ *
+ * @return true if the CQ Results key cache is initialized.
+ */
+ boolean isCqResultsCacheInitialized();
+
+ /**
* Returns true if old value is required for query processing.
*/
boolean isOldValueRequiredForQueryProcessing(Object key);
diff --git
a/geode-cq/src/main/java/org/apache/geode/cache/query/cq/internal/CqQueryImpl.java
b/geode-cq/src/main/java/org/apache/geode/cache/query/cq/internal/CqQueryImpl.java
index eed5568..01c3691 100644
---
a/geode-cq/src/main/java/org/apache/geode/cache/query/cq/internal/CqQueryImpl.java
+++
b/geode-cq/src/main/java/org/apache/geode/cache/query/cq/internal/CqQueryImpl.java
@@ -56,8 +56,6 @@ public abstract class CqQueryImpl implements InternalCqQuery {
protected String queryString;
- static final Object TOKEN = new Object();
-
LocalRegion cqBaseRegion;
protected Query query = null;
diff --git
a/geode-cq/src/main/java/org/apache/geode/cache/query/cq/internal/CqServiceImpl.java
b/geode-cq/src/main/java/org/apache/geode/cache/query/cq/internal/CqServiceImpl.java
index cb54c99..e93ed98 100644
---
a/geode-cq/src/main/java/org/apache/geode/cache/query/cq/internal/CqServiceImpl.java
+++
b/geode-cq/src/main/java/org/apache/geode/cache/query/cq/internal/CqServiceImpl.java
@@ -1347,15 +1347,16 @@ public class CqServiceImpl implements CqService {
boolean error = false;
{
try {
- synchronized (cQuery) {
-// Apply query on new value.
-if (!cqUnfilteredEventsSet_newValue.isEmpty()) {
- executionStartTime = this.stats.startCqQueryExecution();
+ // Apply query on new value.
+ if
[geode] branch release/1.12.0 updated: GEODE-7853: Remove unused field (#4777)
This is an automated email from the ASF dual-hosted git repository.
echobravo pushed a commit to branch release/1.12.0
in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/release/1.12.0 by this push:
new 4b6e7bd GEODE-7853: Remove unused field (#4777)
4b6e7bd is described below
commit 4b6e7bd72aef2a9bf4bf2894eeda6cefd4d598c6
Author: Juan José Ramos
AuthorDate: Fri Mar 6 18:53:12 2020 +
GEODE-7853: Remove unused field (#4777)
Remove unused field and avoid unnecessary calls to
Logger.isTraceEnabled().
(cherry picked from commit a9a7d15fd32ff9ef557270f5d25cbce35a6ebcd3)
---
.../main/java/org/apache/geode/internal/InternalDataSerializer.java | 5 +
1 file changed, 1 insertion(+), 4 deletions(-)
diff --git
a/geode-core/src/main/java/org/apache/geode/internal/InternalDataSerializer.java
b/geode-core/src/main/java/org/apache/geode/internal/InternalDataSerializer.java
index 8428c6a..468a13a 100644
---
a/geode-core/src/main/java/org/apache/geode/internal/InternalDataSerializer.java
+++
b/geode-core/src/main/java/org/apache/geode/internal/InternalDataSerializer.java
@@ -245,10 +245,7 @@ public abstract class InternalDataSerializer extends
DataSerializer {
private static final ConcurrentHashMap
supportedClassesToHolders =
new ConcurrentHashMap<>();
private static final Object listenersSync = new Object();
- @MakeNotStatic
- private static final ConcurrentMap dsfidToClassMap =
- logger.isTraceEnabled(LogMarker.SERIALIZER_WRITE_DSFID_VERBOSE) ? new
ConcurrentHashMap<>()
- : null;
+
private static final ThreadLocal pdxSerializationInProgress = new
ThreadLocal<>();
@MakeNotStatic
private static final CopyOnWriteHashMap>>
classCache =
[geode] branch release/1.12.0 updated: GEODE-7832: Remove Connection Semaphores (#4754)
This is an automated email from the ASF dual-hosted git repository.
echobravo pushed a commit to branch release/1.12.0
in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/release/1.12.0 by this push:
new 37a18a0 GEODE-7832: Remove Connection Semaphores (#4754)
37a18a0 is described below
commit 37a18a0b921c65645700efa202d388ecd0a04ccb
Author: Juan José Ramos
AuthorDate: Wed Mar 4 09:19:20 2020 +
GEODE-7832: Remove Connection Semaphores (#4754)
Removed the semaphores and related methods from DirectChannel and
Connection classes. They were used to constrain messaging when some
undocumented system properties were set.
(cherry picked from commit 2a3e09f2da4793d08d1124b5d5e656285295937d)
---
.../internal/ClusterOperationExecutors.java| 8 -
.../distributed/internal/direct/DirectChannel.java | 200 +
.../apache/geode/internal/cache/properties.html| 34
.../org/apache/geode/internal/tcp/Connection.java | 81 +
4 files changed, 49 insertions(+), 274 deletions(-)
diff --git
a/geode-core/src/main/java/org/apache/geode/distributed/internal/ClusterOperationExecutors.java
b/geode-core/src/main/java/org/apache/geode/distributed/internal/ClusterOperationExecutors.java
index ddd2aff..d16e7fd 100644
---
a/geode-core/src/main/java/org/apache/geode/distributed/internal/ClusterOperationExecutors.java
+++
b/geode-core/src/main/java/org/apache/geode/distributed/internal/ClusterOperationExecutors.java
@@ -38,7 +38,6 @@ import org.apache.geode.internal.logging.log4j.LogMarker;
import org.apache.geode.internal.monitoring.ThreadsMonitoring;
import org.apache.geode.internal.monitoring.ThreadsMonitoringImpl;
import org.apache.geode.internal.monitoring.ThreadsMonitoringImplDummy;
-import org.apache.geode.internal.tcp.Connection;
import org.apache.geode.internal.tcp.ConnectionTable;
import org.apache.geode.logging.internal.log4j.api.LogService;
@@ -375,7 +374,6 @@ public class ClusterOperationExecutors implements
OperationExecutors {
FunctionExecutionPooledExecutor.setIsFunctionExecutionThread(Boolean.TRUE);
try {
ConnectionTable.threadWantsSharedResources();
- Connection.makeReaderThread();
runUntilShutdown(command);
} finally {
ConnectionTable.releaseThreadsSockets();
@@ -388,7 +386,6 @@ public class ClusterOperationExecutors implements
OperationExecutors {
stats.incNumProcessingThreads(1);
try {
ConnectionTable.threadWantsSharedResources();
- Connection.makeReaderThread();
runUntilShutdown(command);
} finally {
ConnectionTable.releaseThreadsSockets();
@@ -400,7 +397,6 @@ public class ClusterOperationExecutors implements
OperationExecutors {
stats.incHighPriorityThreads(1);
try {
ConnectionTable.threadWantsSharedResources();
- Connection.makeReaderThread();
runUntilShutdown(command);
} finally {
ConnectionTable.releaseThreadsSockets();
@@ -412,7 +408,6 @@ public class ClusterOperationExecutors implements
OperationExecutors {
stats.incWaitingThreads(1);
try {
ConnectionTable.threadWantsSharedResources();
- Connection.makeReaderThread();
runUntilShutdown(command);
} finally {
ConnectionTable.releaseThreadsSockets();
@@ -424,7 +419,6 @@ public class ClusterOperationExecutors implements
OperationExecutors {
stats.incPartitionedRegionThreads(1);
try {
ConnectionTable.threadWantsSharedResources();
- Connection.makeReaderThread();
runUntilShutdown(command);
} finally {
ConnectionTable.releaseThreadsSockets();
@@ -436,7 +430,6 @@ public class ClusterOperationExecutors implements
OperationExecutors {
stats.incNumSerialThreads(1);
try {
ConnectionTable.threadWantsSharedResources();
- Connection.makeReaderThread();
runUntilShutdown(command);
} finally {
ConnectionTable.releaseThreadsSockets();
@@ -816,7 +809,6 @@ public class ClusterOperationExecutors implements
OperationExecutors {
private void doSerialPooledThread(Runnable command) {
ConnectionTable.threadWantsSharedResources();
- Connection.makeReaderThread();
try {
command.run();
} finally {
diff --git
a/geode-core/src/main/java/org/apache/geode/distributed/internal/direct/DirectChannel.java
b/geode-core/src/main/java/org/apache/geode/distributed/internal/direct/DirectChannel.java
index 10b0108..4799270 100644
---
a/geode-core/src/main/java/org/apache/geode/distributed/internal/direct/DirectChannel.java
+++
b/geode-core/src/main/java/org/apache/geode/distributed/internal/direct/DirectChannel.java
@@ -25,7 +25,6 @@ import java.util.List;
import java.util.Map;
import java.util.Properties;
import java.util.Set;
-import java.util.concurrent.Semaphore;
import org.apache.logging.log4j.Logger;
@@ -36,7 +35,6 @@ import
[geode] branch develop updated (f84d3e6 -> 2d2a3f8)
This is an automated email from the ASF dual-hosted git repository. bschuchardt pushed a change to branch develop in repository https://gitbox.apache.org/repos/asf/geode.git. from f84d3e6 GEODE-7895:Create integration tests for EXPIRE command in Redis Adapter (#4831) add 2d2a3f8 GEODE-7884: server hangs due to IllegalStateException (#4822) No new revisions were added by this update. Summary of changes: .../internal/InternalDistributedSystem.java| 2 +- .../org/apache/geode/internal/SystemTimer.java | 367 +++-- .../geode/internal/admin/StatAlertsManager.java| 2 +- .../geode/internal/cache/ExpirationScheduler.java | 2 +- .../geode/internal/cache/GemFireCacheImpl.java | 2 +- .../cache/partitioned/PRSanityCheckMessage.java| 2 +- .../internal/cache/tier/sockets/AcceptorImpl.java | 2 +- .../org/apache/geode/internal/tcp/Connection.java | 30 +- .../apache/geode/internal/tcp/ConnectionTable.java | 22 +- .../org/apache/geode/internal/SystemTimerTest.java | 162 + 10 files changed, 329 insertions(+), 264 deletions(-) create mode 100644 geode-core/src/test/java/org/apache/geode/internal/SystemTimerTest.java
[geode] branch develop updated (9cddaec -> f84d3e6)
This is an automated email from the ASF dual-hosted git repository. jensdeppe pushed a change to branch develop in repository https://gitbox.apache.org/repos/asf/geode.git. from 9cddaec GEODE-7893: Fix Analyzer dependency in geode-lucene (#4829) add f84d3e6 GEODE-7895:Create integration tests for EXPIRE command in Redis Adapter (#4831) No new revisions were added by this update. Summary of changes: .../apache/geode/redis/ListsIntegrationTest.java | 5 +- .../geode/redis/SortedSetsIntegrationTest.java | 8 +- .../apache/geode/redis/StringsIntegrationTest.java | 5 - .../geode/redis/general/ExpireIntegrationTest.java | 484 + .../internal/executor/ExpirationExecutor.java | 14 +- .../redis/internal/executor/ExpireExecutor.java| 14 +- 6 files changed, 504 insertions(+), 26 deletions(-) create mode 100644 geode-redis/src/integrationTest/java/org/apache/geode/redis/general/ExpireIntegrationTest.java
