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())
