cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From slebre...@apache.org
Subject cassandra git commit: Fix test build
Date Fri, 04 Sep 2015 15:30:49 GMT
Repository: cassandra
Updated Branches:
  refs/heads/cassandra-3.0 9658ee9fa -> 8f249a67d


Fix test build


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

Branch: refs/heads/cassandra-3.0
Commit: 8f249a67d99b11367ff28be86443e20d61caba47
Parents: 9658ee9
Author: Sylvain Lebresne <sylvain@datastax.com>
Authored: Fri Sep 4 17:30:41 2015 +0200
Committer: Sylvain Lebresne <sylvain@datastax.com>
Committed: Fri Sep 4 17:30:41 2015 +0200

----------------------------------------------------------------------
 .../apache/cassandra/db/SinglePartitionSliceCommandTest.java | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/8f249a67/test/unit/org/apache/cassandra/db/SinglePartitionSliceCommandTest.java
----------------------------------------------------------------------
diff --git a/test/unit/org/apache/cassandra/db/SinglePartitionSliceCommandTest.java b/test/unit/org/apache/cassandra/db/SinglePartitionSliceCommandTest.java
index 15b566e..4b7f15a 100644
--- a/test/unit/org/apache/cassandra/db/SinglePartitionSliceCommandTest.java
+++ b/test/unit/org/apache/cassandra/db/SinglePartitionSliceCommandTest.java
@@ -30,7 +30,7 @@ import org.apache.cassandra.db.rows.Cell;
 import org.apache.cassandra.db.rows.Row;
 import org.apache.cassandra.db.rows.UnfilteredRowIterator;
 import org.apache.cassandra.exceptions.ConfigurationException;
-import org.apache.cassandra.io.util.ByteBufferDataInput;
+import org.apache.cassandra.io.util.DataInputBuffer;
 import org.apache.cassandra.io.util.DataInputPlus;
 import org.apache.cassandra.io.util.DataOutputBuffer;
 import org.apache.cassandra.net.MessagingService;
@@ -99,7 +99,7 @@ public class SinglePartitionSliceCommandTest
 
         DataOutputBuffer out = new DataOutputBuffer((int) ReadCommand.legacyReadCommandSerializer.serializedSize(cmd,
MessagingService.VERSION_21));
         ReadCommand.legacyReadCommandSerializer.serialize(cmd, out, MessagingService.VERSION_21);
-        DataInputPlus in = new ByteBufferDataInput(out.buffer(), null, 0, 0);
+        DataInputPlus in = new DataInputBuffer(out.buffer(), true);
         cmd = ReadCommand.legacyReadCommandSerializer.deserialize(in, MessagingService.VERSION_21);
 
         logger.debug("ReadCommand: {}", cmd);
@@ -163,7 +163,7 @@ public class SinglePartitionSliceCommandTest
         response = ReadResponse.createDataResponse(pi, cmd.columnFilter());
         out = new DataOutputBuffer((int) ReadResponse.serializer.serializedSize(response,
MessagingService.VERSION_30));
         ReadResponse.serializer.serialize(response, out, MessagingService.VERSION_30);
-        in = new ByteBufferDataInput(out.buffer(), null, 0, 0);
+        in = new DataInputBuffer(out.buffer(), true);
         dst = ReadResponse.serializer.deserialize(in, MessagingService.VERSION_30);
         pi = dst.makeIterator(cfm, cmd);
         checkForS(pi);
@@ -174,7 +174,7 @@ public class SinglePartitionSliceCommandTest
         response = ReadResponse.createDataResponse(pi, cmd.columnFilter());
         out = new DataOutputBuffer((int) ReadResponse.serializer.serializedSize(response,
MessagingService.VERSION_30));
         ReadResponse.serializer.serialize(response, out, MessagingService.VERSION_30);
-        in = new ByteBufferDataInput(out.buffer(), null, 0, 0);
+        in = new DataInputBuffer(out.buffer(), true);
         dst = ReadResponse.serializer.deserialize(in, MessagingService.VERSION_30);
         pi = dst.makeIterator(cfm, cmd);
         checkForS(pi);


Mime
View raw message