From 082aeab0a77698fc604c083a9550fbb22f869cce Mon Sep 17 00:00:00 2001
From: Asias He <asias@cloudius-systems.com>
Date: Wed, 17 Jun 2015 13:06:13 +0800
Subject: [PATCH] streaming: Convert StreamInitMessage.java to C++

---
 ...nitMessage.java => stream_init_message.hh} | 29 +++++++++----------
 streaming/streaming.cc                        |  1 +
 2 files changed, 14 insertions(+), 16 deletions(-)
 rename streaming/messages/{StreamInitMessage.java => stream_init_message.hh} (89%)

diff --git a/streaming/messages/StreamInitMessage.java b/streaming/messages/stream_init_message.hh
similarity index 89%
rename from streaming/messages/StreamInitMessage.java
rename to streaming/messages/stream_init_message.hh
index 0937f7197c..e23da14f44 100644
--- a/streaming/messages/StreamInitMessage.java
+++ b/streaming/messages/stream_init_message.hh
@@ -14,29 +14,22 @@
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
+ *
+ * Modified by Cloudius Systems.
+ * Copyright 2015 Cloudius Systems.
  */
-package org.apache.cassandra.streaming.messages;
 
-import java.io.DataInput;
-import java.io.IOException;
-import java.net.InetAddress;
-import java.nio.ByteBuffer;
-import java.util.UUID;
+#pragma once
 
-import org.apache.cassandra.db.TypeSizes;
-import org.apache.cassandra.io.IVersionedSerializer;
-import org.apache.cassandra.io.util.DataOutputBuffer;
-import org.apache.cassandra.io.util.DataOutputPlus;
-import org.apache.cassandra.net.CompactEndpointSerializationHelper;
-import org.apache.cassandra.net.MessagingService;
-import org.apache.cassandra.utils.UUIDSerializer;
+namespace streaming {
+namespace messages {
 
 /**
  * StreamInitMessage is first sent from the node where {@link org.apache.cassandra.streaming.StreamSession} is started,
  * to initiate corresponding {@link org.apache.cassandra.streaming.StreamSession} on the other side.
  */
-public class StreamInitMessage
-{
+class stream_init_message {
+#if 0
     public static IVersionedSerializer<StreamInitMessage> serializer = new StreamInitMessageSerializer();
 
     public final InetAddress from;
@@ -132,4 +125,8 @@ public class StreamInitMessage
             return size;
         }
     }
-}
+#endif
+};
+
+} // namespace messages
+} // namespace streaming
diff --git a/streaming/streaming.cc b/streaming/streaming.cc
index 3573a97e4d..3a9c4137ee 100644
--- a/streaming/streaming.cc
+++ b/streaming/streaming.cc
@@ -6,3 +6,4 @@
 // out-of-line implementations.
 
 #include "streaming/messages/stream_message.hh"
+#include "streaming/messages/stream_init_message.hh"