From 2b3e73da724ba172a561e1ca7e4988e4c53aec1f Mon Sep 17 00:00:00 2001 From: Brandon Williams Date: Wed, 27 Jul 2011 22:47:02 +0000 Subject: [PATCH] Gossiper notifies of local state changes. Patch by Sam Overton, reviewed by brandonwilliams for CASSANDRA-2948 git-svn-id: https://svn.apache.org/repos/asf/cassandra/branches/cassandra-0.8@1151659 13f79535-47bb-0310-9956-ffa450edef68 --- src/java/org/apache/cassandra/gms/Gossiper.java | 1 + src/java/org/apache/cassandra/service/StorageService.java | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/src/java/org/apache/cassandra/gms/Gossiper.java b/src/java/org/apache/cassandra/gms/Gossiper.java index b8eefedaae..dc59662413 100644 --- a/src/java/org/apache/cassandra/gms/Gossiper.java +++ b/src/java/org/apache/cassandra/gms/Gossiper.java @@ -981,6 +981,7 @@ public class Gossiper implements IFailureDetectionEventListener EndpointState epState = endpointStateMap.get(FBUtilities.getLocalAddress()); assert epState != null; epState.addApplicationState(state, value); + doNotifications(FBUtilities.getLocalAddress(), state, value); } public void stop() diff --git a/src/java/org/apache/cassandra/service/StorageService.java b/src/java/org/apache/cassandra/service/StorageService.java index 4701cfc5d3..78ad474b50 100644 --- a/src/java/org/apache/cassandra/service/StorageService.java +++ b/src/java/org/apache/cassandra/service/StorageService.java @@ -1913,7 +1913,7 @@ public class StorageService implements IEndpointStateChangeSubscriber, StorageSe // ring ranges and endpoints associated with them // this used to determine what nodes should we ping about range data - Multimap rangeAddresses = strategy.getRangeAddresses(tokenMetaClone); + Multimap rangeAddresses = strategy.getRangeAddresses(tokenMetadata_); // calculated parts of the ranges to request/stream from/to nodes in the ring Pair, Set> rangesPerTable = calculateStreamAndFetchRanges(currentRanges, updatedRanges);