Author: brandonwilliams Date: Wed Jul 27 22:47:02 2011 New Revision: 1151659
URL: http://svn.apache.org/viewvc?rev=1151659&view=rev Log: Gossiper notifies of local state changes. Patch by Sam Overton, reviewed by brandonwilliams for CASSANDRA-2948 Modified: cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/gms/Gossiper.java cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageService.java Modified: cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/gms/Gossiper.java URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/gms/Gossiper.java?rev=1151659&r1=1151658&r2=1151659&view=diff ============================================================================== --- cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/gms/Gossiper.java (original) +++ cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/gms/Gossiper.java Wed Jul 27 22:47:02 2011 @@ -981,6 +981,7 @@ public class Gossiper implements IFailur EndpointState epState = endpointStateMap.get(FBUtilities.getLocalAddress()); assert epState != null; epState.addApplicationState(state, value); + doNotifications(FBUtilities.getLocalAddress(), state, value); } public void stop() Modified: cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageService.java URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageService.java?rev=1151659&r1=1151658&r2=1151659&view=diff ============================================================================== --- cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageService.java (original) +++ cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageService.java Wed Jul 27 22:47:02 2011 @@ -1913,7 +1913,7 @@ public class StorageService implements I // ring ranges and endpoints associated with them // this used to determine what nodes should we ping about range data - Multimap<Range, InetAddress> rangeAddresses = strategy.getRangeAddresses(tokenMetaClone); + Multimap<Range, InetAddress> rangeAddresses = strategy.getRangeAddresses(tokenMetadata_); // calculated parts of the ranges to request/stream from/to nodes in the ring Pair<Set<Range>, Set<Range>> rangesPerTable = calculateStreamAndFetchRanges(currentRanges, updatedRanges);
