cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From brandonwilli...@apache.org
Subject svn commit: r1164237 - /cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageService.java
Date Thu, 01 Sep 2011 19:51:49 GMT
Author: brandonwilliams
Date: Thu Sep  1 19:51:48 2011
New Revision: 1164237

URL: http://svn.apache.org/viewvc?rev=1164237&view=rev
Log:
Weaken inflexible inserts for future additions

Modified:
    cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageService.java

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=1164237&r1=1164236&r2=1164237&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
Thu Sep  1 19:51:48 2011
@@ -771,7 +771,7 @@ public class StorageService implements I
      */
     private void handleStateBootstrap(InetAddress endpoint, String[] pieces)
     {
-        assert pieces.length == 2;
+        assert pieces.length >= 2;
         Token token = getPartitioner().getTokenFactory().fromString(pieces[1]);
 
         if (logger_.isDebugEnabled())
@@ -858,7 +858,7 @@ public class StorageService implements I
      */
     private void handleStateLeaving(InetAddress endpoint, String[] pieces)
     {
-        assert pieces.length == 2;
+        assert pieces.length >= 2;
         String moveValue = pieces[1];
         Token token = getPartitioner().getTokenFactory().fromString(moveValue);
 
@@ -893,7 +893,7 @@ public class StorageService implements I
      */
     private void handleStateLeft(InetAddress endpoint, String[] pieces)
     {
-        assert pieces.length == 2;
+        assert pieces.length >= 2;
         Token token = getPartitioner().getTokenFactory().fromString(pieces[1]);
 
         if (logger_.isDebugEnabled())
@@ -910,7 +910,7 @@ public class StorageService implements I
      */
     private void handleStateMoving(InetAddress endpoint, String[] pieces)
     {
-        assert pieces.length == 2;
+        assert pieces.length >= 2;
         Token token = getPartitioner().getTokenFactory().fromString(pieces[1]);
 
         if (logger_.isDebugEnabled())



Mime
View raw message