You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by sl...@apache.org on 2015/09/04 17:30:49 UTC
cassandra git commit: Fix test build
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 <sy...@datastax.com>
Authored: Fri Sep 4 17:30:41 2015 +0200
Committer: Sylvain Lebresne <sy...@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);