You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by km...@apache.org on 2016/12/23 21:10:14 UTC
[21/25] geode git commit: GEODE-2238: Fix how peers discover locators
with cluster config
GEODE-2238: Fix how peers discover locators with cluster config
Call super.process last in StartupResponseWithVersionMessage, so that
that threads waiting on the response will have the results of
dm.addHostedLocators.
Project: http://git-wip-us.apache.org/repos/asf/geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/geode/commit/93994481
Tree: http://git-wip-us.apache.org/repos/asf/geode/tree/93994481
Diff: http://git-wip-us.apache.org/repos/asf/geode/diff/93994481
Branch: refs/heads/feature/GEODE-2231
Commit: 93994481e361d590ae201e7cbecfd18ee45603b4
Parents: 16e2cfc
Author: Dan Smith <up...@apache.org>
Authored: Tue Dec 20 17:38:47 2016 -0800
Committer: Karen Miller <km...@pivotal.io>
Committed: Fri Dec 23 13:09:28 2016 -0800
----------------------------------------------------------------------
.../internal/StartupMessageReplyProcessor.java | 11 -----------
.../internal/StartupResponseWithVersionMessage.java | 2 +-
2 files changed, 1 insertion(+), 12 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/geode/blob/93994481/geode-core/src/main/java/org/apache/geode/distributed/internal/StartupMessageReplyProcessor.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/StartupMessageReplyProcessor.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/StartupMessageReplyProcessor.java
index de6e71f..f90f0da 100644
--- a/geode-core/src/main/java/org/apache/geode/distributed/internal/StartupMessageReplyProcessor.java
+++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/StartupMessageReplyProcessor.java
@@ -101,15 +101,4 @@ public class StartupMessageReplyProcessor extends ReplyProcessor21 {
// }
// }
}
-
- /**
- * overridden from ReplyProcessor21 to allow early-out. If an existing member accepted or rejected
- * us then we are done.
- */
- @Override
- protected boolean canStopWaiting() {
- return this.receivedAcceptance || this.receivedRejectionMessage;
- }
-
-
}
http://git-wip-us.apache.org/repos/asf/geode/blob/93994481/geode-core/src/main/java/org/apache/geode/distributed/internal/StartupResponseWithVersionMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/StartupResponseWithVersionMessage.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/StartupResponseWithVersionMessage.java
index 6276d63..5bcbb47 100644
--- a/geode-core/src/main/java/org/apache/geode/distributed/internal/StartupResponseWithVersionMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/StartupResponseWithVersionMessage.java
@@ -57,7 +57,6 @@ public class StartupResponseWithVersionMessage extends StartupResponseMessage {
@Override
protected void process(DistributionManager dm) {
- super.process(dm);
if (this.hostedLocators != null) {
dm.addHostedLocators(getSender(), this.hostedLocators, this.isSharedConfigurationEnabled);
}
@@ -65,6 +64,7 @@ public class StartupResponseWithVersionMessage extends StartupResponseMessage {
logger.debug("Received StartupResponseWithVersionMessage from a member with version: {}",
this.version);
}
+ super.process(dm);
}
public int getDSFID() {