You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by mh...@apache.org on 2022/05/13 21:31:36 UTC
[geode] branch develop updated: GEODE-10306 Fixing an order issue that can lead to problems when stopping (#7682)
This is an automated email from the ASF dual-hosted git repository.
mhanson pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/develop by this push:
new 20844a8494 GEODE-10306 Fixing an order issue that can lead to problems when stopping (#7682)
20844a8494 is described below
commit 20844a84947a746ec4c740acf5af6734bfb272c1
Author: mhansonp <ha...@vmware.com>
AuthorDate: Fri May 13 14:31:31 2022 -0700
GEODE-10306 Fixing an order issue that can lead to problems when stopping (#7682)
When stopping the cache server, the acceptor is last which should not be the case. It should be first so new data stops coming in.
---
.../geode/internal/cache/CacheServerImpl.java | 21 +++++++++++----------
1 file changed, 11 insertions(+), 10 deletions(-)
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheServerImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheServerImpl.java
index c8f8b96033..25d6f70b33 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheServerImpl.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheServerImpl.java
@@ -460,6 +460,16 @@ public class CacheServerImpl extends AbstractCacheServer implements Distribution
}
RuntimeException firstException = null;
+ try {
+ if (acceptor != null) {
+ acceptor.close();
+ }
+ } catch (RuntimeException e) {
+ logger.warn("CacheServer - Error closing acceptor monitor", e);
+ if (firstException != null) {
+ firstException = e;
+ }
+ }
try {
if (loadMonitor != null) {
@@ -479,16 +489,7 @@ public class CacheServerImpl extends AbstractCacheServer implements Distribution
firstException = e;
}
- try {
- if (acceptor != null) {
- acceptor.close();
- }
- } catch (RuntimeException e) {
- logger.warn("CacheServer - Error closing acceptor monitor", e);
- if (firstException != null) {
- firstException = e;
- }
- }
+
if (firstException != null) {
throw firstException;