You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@cassandra.apache.org by br...@apache.org on 2011/11/10 01:47:31 UTC

svn commit: r1200066 - /cassandra/branches/cassandra-1.0/src/java/org/apache/cassandra/service/LoadBroadcaster.java

Author: brandonwilliams
Date: Thu Nov 10 00:47:30 2011
New Revision: 1200066

URL: http://svn.apache.org/viewvc?rev=1200066&view=rev
Log:
LoadBroadcaster should remove load info for nodes that leave.
Patch by brandonwilliams, reviewed by jbellis for CASSANDRA-3475

Modified:
    cassandra/branches/cassandra-1.0/src/java/org/apache/cassandra/service/LoadBroadcaster.java

Modified: cassandra/branches/cassandra-1.0/src/java/org/apache/cassandra/service/LoadBroadcaster.java
URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-1.0/src/java/org/apache/cassandra/service/LoadBroadcaster.java?rev=1200066&r1=1200065&r2=1200066&view=diff
==============================================================================
--- cassandra/branches/cassandra-1.0/src/java/org/apache/cassandra/service/LoadBroadcaster.java (original)
+++ cassandra/branches/cassandra-1.0/src/java/org/apache/cassandra/service/LoadBroadcaster.java Thu Nov 10 00:47:30 2011
@@ -64,7 +64,10 @@ public class LoadBroadcaster implements 
 
     public void onRestart(InetAddress endpoint, EndpointState state) {}
 
-    public void onRemove(InetAddress endpoint) {}
+    public void onRemove(InetAddress endpoint)
+    {
+        loadInfo_.remove(endpoint);
+    }
 
     public Map<InetAddress, Double> getLoadInfo()
     {