You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by vi...@apache.org on 2012/06/15 02:57:55 UTC
git commit: Fix missing commit for move protocol versions into
MessagingService
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 <vi...@gmail.com>
Authored: Thu Jun 14 17:56:41 2012 -0700
Committer: Vijay Parthasarathy <vi...@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);