Updated Branches: refs/heads/trunk aae0dfc92 -> 95b833d42
Fix missing commit for move protocol versions into MessagingService Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/95b833d4 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/95b833d4 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/95b833d4 Branch: refs/heads/trunk Commit: 95b833d42f9b6bec8f18aa0cdeca42c620b360b7 Parents: aae0dfc Author: Vijay Parthasarathy <vijay2...@gmail.com> Authored: Thu Jun 14 17:56:41 2012 -0700 Committer: Vijay Parthasarathy <vijay2...@gmail.com> Committed: Thu Jun 14 17:56:41 2012 -0700 ---------------------------------------------------------------------- .../compress/CompressedFileStreamTask.java | 3 +-- 1 files changed, 1 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/95b833d4/src/java/org/apache/cassandra/streaming/compress/CompressedFileStreamTask.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/streaming/compress/CompressedFileStreamTask.java b/src/java/org/apache/cassandra/streaming/compress/CompressedFileStreamTask.java index 5f00def..1a281fc 100644 --- a/src/java/org/apache/cassandra/streaming/compress/CompressedFileStreamTask.java +++ b/src/java/org/apache/cassandra/streaming/compress/CompressedFileStreamTask.java @@ -28,7 +28,6 @@ import java.util.List; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import org.apache.cassandra.gms.Gossiper; import org.apache.cassandra.io.compress.CompressionMetadata; import org.apache.cassandra.io.util.FileUtils; import org.apache.cassandra.io.util.RandomAccessReader; @@ -62,7 +61,7 @@ public class CompressedFileStreamTask extends FileStreamTask byte[] transferBuffer = null; // write header - ByteBuffer headerBuffer = MessagingService.instance().constructStreamHeader(header, false, Gossiper.instance.getVersion(to)); + ByteBuffer headerBuffer = MessagingService.instance().constructStreamHeader(header, false, MessagingService.instance().getVersion(to)); socket.getOutputStream().write(ByteBufferUtil.getArray(headerBuffer)); RandomAccessReader file = RandomAccessReader.open(new File(header.file.getFilename()), true);