Skip to content

Commit

Permalink
GEODE-2238: Fix how peers discover locators with cluster config
Browse files Browse the repository at this point in the history
Call super.process last in StartupResponseWithVersionMessage, so that
that threads waiting on the response will have the results of
dm.addHostedLocators.
  • Loading branch information
upthewaterspout committed Dec 22, 2016
1 parent 93d4455 commit f097d7a
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 12 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -101,15 +101,4 @@ protected void preWait() {
// }
// }
}

/**
* 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;
}


}
Original file line number Diff line number Diff line change
Expand Up @@ -57,14 +57,14 @@ public StartupResponseWithVersionMessage() {

@Override
protected void process(DistributionManager dm) {
super.process(dm);
if (this.hostedLocators != null) {
dm.addHostedLocators(getSender(), this.hostedLocators, this.isSharedConfigurationEnabled);
}
if (logger.isDebugEnabled()) {
logger.debug("Received StartupResponseWithVersionMessage from a member with version: {}",
this.version);
}
super.process(dm);
}

public int getDSFID() {
Expand Down

0 comments on commit f097d7a

Please sign in to comment.