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 <[email protected]> Authored: Wed Oct 21 10:31:03 2015 -0700 Committer: Bruce Schuchardt <[email protected]> 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; }
