geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kmil...@apache.org
Subject [21/25] geode git commit: GEODE-2238: Fix how peers discover locators with cluster config
Date Fri, 23 Dec 2016 21:10:14 GMT
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 <upthewaterspout@apache.org>
Authored: Tue Dec 20 17:38:47 2016 -0800
Committer: Karen Miller <kmiller@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() {


Mime
View raw message