Merge branch 'cassandra-2.0' into trunk

Conflicts:
        src/java/org/apache/cassandra/db/PagedRangeCommand.java
        src/java/org/apache/cassandra/db/RangeSliceCommand.java


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

Branch: refs/heads/trunk
Commit: f8138a3c2e93d4dbc92aee6455892c6acc8a010c
Parents: 1475d92 20793b0
Author: Sylvain Lebresne <sylv...@datastax.com>
Authored: Tue Nov 5 16:35:19 2013 +0100
Committer: Sylvain Lebresne <sylv...@datastax.com>
Committed: Tue Nov 5 16:35:19 2013 +0100

----------------------------------------------------------------------
 CHANGES.txt                                            |  1 +
 .../org/apache/cassandra/db/PagedRangeCommand.java     | 13 +++++++++++--
 .../org/apache/cassandra/db/RangeSliceCommand.java     |  2 +-
 3 files changed, 13 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/f8138a3c/CHANGES.txt
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/cassandra/blob/f8138a3c/src/java/org/apache/cassandra/db/PagedRangeCommand.java
----------------------------------------------------------------------
diff --cc src/java/org/apache/cassandra/db/PagedRangeCommand.java
index d813036,e152f43..0e24859
--- a/src/java/org/apache/cassandra/db/PagedRangeCommand.java
+++ b/src/java/org/apache/cassandra/db/PagedRangeCommand.java
@@@ -130,9 -138,9 +136,9 @@@ public class PagedRangeCommand extends 
              out.writeInt(cmd.rowFilter.size());
              for (IndexExpression expr : cmd.rowFilter)
              {
 -                ByteBufferUtil.writeWithShortLength(expr.column_name, out);
 -                out.writeInt(expr.op.getValue());
 +                ByteBufferUtil.writeWithShortLength(expr.column, out);
 +                out.writeInt(expr.operator.ordinal());
-                 ByteBufferUtil.writeWithLength(expr.value, out);
+                 ByteBufferUtil.writeWithShortLength(expr.value, out);
              }
  
              out.writeInt(cmd.limit);
@@@ -180,9 -191,9 +189,9 @@@
              size += TypeSizes.NATIVE.sizeof(cmd.rowFilter.size());
              for (IndexExpression expr : cmd.rowFilter)
              {
 -                size += 
TypeSizes.NATIVE.sizeofWithShortLength(expr.column_name);
 -                size += TypeSizes.NATIVE.sizeof(expr.op.getValue());
 +                size += TypeSizes.NATIVE.sizeofWithShortLength(expr.column);
 +                size += TypeSizes.NATIVE.sizeof(expr.operator.ordinal());
-                 size += TypeSizes.NATIVE.sizeofWithLength(expr.value);
+                 size += TypeSizes.NATIVE.sizeofWithShortLength(expr.value);
              }
  
              size += TypeSizes.NATIVE.sizeof(cmd.limit);

http://git-wip-us.apache.org/repos/asf/cassandra/blob/f8138a3c/src/java/org/apache/cassandra/db/RangeSliceCommand.java
----------------------------------------------------------------------
diff --cc src/java/org/apache/cassandra/db/RangeSliceCommand.java
index 28b86f8,4aa1595..a9a48a0
--- a/src/java/org/apache/cassandra/db/RangeSliceCommand.java
+++ b/src/java/org/apache/cassandra/db/RangeSliceCommand.java
@@@ -227,9 -308,9 +227,9 @@@ class RangeSliceCommandSerializer imple
              size += TypeSizes.NATIVE.sizeof(rsc.rowFilter.size());
              for (IndexExpression expr : rsc.rowFilter)
              {
 -                size += 
TypeSizes.NATIVE.sizeofWithShortLength(expr.column_name);
 -                size += TypeSizes.NATIVE.sizeof(expr.op.getValue());
 +                size += TypeSizes.NATIVE.sizeofWithShortLength(expr.column);
 +                size += TypeSizes.NATIVE.sizeof(expr.operator.ordinal());
-                 size += TypeSizes.NATIVE.sizeofWithLength(expr.value);
+                 size += TypeSizes.NATIVE.sizeofWithShortLength(expr.value);
              }
          }
          size += AbstractBounds.serializer.serializedSize(rsc.keyRange, 
version);

Reply via email to