[4/4] git commit: Fix merge

2013-12-22 Thread aleksey
Fix merge


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/34235ad7
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/34235ad7
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/34235ad7

Branch: refs/heads/trunk
Commit: 34235ad7b5722a5a5ee9680ba3a2d563a67ecc6f
Parents: 85863e2
Author: Aleksey Yeschenko alek...@apache.org
Authored: Sun Dec 22 20:10:59 2013 +0300
Committer: Aleksey Yeschenko alek...@apache.org
Committed: Sun Dec 22 20:10:59 2013 +0300

--
 src/java/org/apache/cassandra/thrift/ThriftValidation.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
--


http://git-wip-us.apache.org/repos/asf/cassandra/blob/34235ad7/src/java/org/apache/cassandra/thrift/ThriftValidation.java
--
diff --git a/src/java/org/apache/cassandra/thrift/ThriftValidation.java 
b/src/java/org/apache/cassandra/thrift/ThriftValidation.java
index b597203..d491636 100644
--- a/src/java/org/apache/cassandra/thrift/ThriftValidation.java
+++ b/src/java/org/apache/cassandra/thrift/ThriftValidation.java
@@ -268,7 +268,7 @@ public class ThriftValidation
 if (range.count  0)
 throw new 
org.apache.cassandra.exceptions.InvalidRequestException(get_slice requires 
non-negative count);
 
-int maxNameLength = org.apache.cassandra.db.Column.MAX_NAME_LENGTH;
+int maxNameLength = Cell.MAX_NAME_LENGTH;
 if (range.start.remaining()  maxNameLength)
 throw new 
org.apache.cassandra.exceptions.InvalidRequestException(range start length 
cannot be larger than  + maxNameLength);
 if (range.finish.remaining()  maxNameLength)



[4/4] git commit: fix merge from 1.1

2012-11-12 Thread jbellis
fix merge from 1.1


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/66001665
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/66001665
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/66001665

Branch: refs/heads/cassandra-1.2
Commit: 660016658f033875f4a442b5f9fdd5875f610cb9
Parents: 3e77082
Author: Jonathan Ellis jbel...@apache.org
Authored: Mon Nov 12 16:14:44 2012 -0600
Committer: Jonathan Ellis jbel...@apache.org
Committed: Mon Nov 12 16:14:44 2012 -0600

--
 .../org/apache/cassandra/service/StorageProxy.java |   18 ++-
 1 files changed, 12 insertions(+), 6 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/cassandra/blob/66001665/src/java/org/apache/cassandra/service/StorageProxy.java
--
diff --git a/src/java/org/apache/cassandra/service/StorageProxy.java 
b/src/java/org/apache/cassandra/service/StorageProxy.java
index 33266c7..b747075 100644
--- a/src/java/org/apache/cassandra/service/StorageProxy.java
+++ b/src/java/org/apache/cassandra/service/StorageProxy.java
@@ -41,7 +41,9 @@ import org.apache.cassandra.config.DatabaseDescriptor;
 import org.apache.cassandra.config.Schema;
 import org.apache.cassandra.db.*;
 import org.apache.cassandra.db.Table;
+import org.apache.cassandra.db.filter.IDiskAtomFilter;
 import org.apache.cassandra.db.filter.QueryPath;
+import org.apache.cassandra.db.filter.SliceQueryFilter;
 import org.apache.cassandra.db.marshal.UUIDType;
 import org.apache.cassandra.dht.AbstractBounds;
 import org.apache.cassandra.dht.Bounds;
@@ -1091,8 +1093,11 @@ public class StorageProxy implements StorageProxyMBean
 // now scan until we have enough results
 try
 {
-final SlicePredicate emptyPredicate = getEmptySlicePredicate();
-SlicePredicate commandPredicate = command.predicate;
+final IDiskAtomFilter emptyPredicate = new 
SliceQueryFilter(ByteBufferUtil.EMPTY_BYTE_BUFFER,
+
ByteBufferUtil.EMPTY_BYTE_BUFFER,
+false,
+-1);
+IDiskAtomFilter commandPredicate = command.predicate;
 
 int columnsCount = 0;
 rows = new ArrayListRow();
@@ -1174,11 +1179,12 @@ public class StorageProxy implements StorageProxyMBean
 return trim(command, rows);
 }
 
-private static SlicePredicate getEmptySlicePredicate()
+private static IDiskAtomFilter getEmptySlicePredicate()
 {
-final SliceRange emptySliceRange =
-new SliceRange(ByteBufferUtil.EMPTY_BYTE_BUFFER, 
ByteBufferUtil.EMPTY_BYTE_BUFFER, false, -1);
-return new SlicePredicate().setSlice_range(emptySliceRange);
+return new SliceQueryFilter(ByteBufferUtil.EMPTY_BYTE_BUFFER,
+ByteBufferUtil.EMPTY_BYTE_BUFFER,
+false,
+-1);
 }
 
 private static ListRow trim(RangeSliceCommand command, ListRow rows)