You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by bs...@apache.org on 2015/10/21 19:31:26 UTC
[2/2] incubator-geode git commit: GEODE-77: installing initial view
GEODE-77: installing initial view
The membership manager was not installing the initial view into the
DistributionManager. This was causing its waitForViewInstallation method
to hang if the view in question was the member's initial view
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/0c1008e6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/0c1008e6
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/0c1008e6
Branch: refs/heads/feature/GEODE-77
Commit: 0c1008e659700b2515994cfc91cae72ba1857f06
Parents: 481574d
Author: Bruce Schuchardt <bs...@pivotal.io>
Authored: Wed Oct 21 10:31:03 2015 -0700
Committer: Bruce Schuchardt <bs...@pivotal.io>
Committed: Wed Oct 21 10:31:03 2015 -0700
----------------------------------------------------------------------
.../internal/membership/gms/mgr/GMSMembershipManager.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/0c1008e6/gemfire-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/mgr/GMSMembershipManager.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/mgr/GMSMembershipManager.java b/gemfire-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/mgr/GMSMembershipManager.java
index a102ac2..204cc0b 100755
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/mgr/GMSMembershipManager.java
+++ b/gemfire-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/mgr/GMSMembershipManager.java
@@ -799,6 +799,10 @@ public class GMSMembershipManager implements MembershipManager, Manager
logger.info(LogMarker.DISTRIBUTION, LocalizedMessage.create(
LocalizedStrings.GroupMembershipService_CONNECTED_TO_JGROUPS_CHANNEL_TOOK__0__MS, delta));
+ NetView initialView = services.getJoinLeave().getView();
+ latestView = new NetView(initialView, initialView.getViewId());
+ listener.viewInstalled(latestView);
+
} catch (RuntimeException ex) {
throw ex;
}