streaming: Convert StreamInitMessage.java to C++

This commit is contained in:
Asias He
2015-06-17 13:06:13 +08:00
parent 15a1d71049
commit 082aeab0a7
2 changed files with 14 additions and 16 deletions

View File

@@ -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

View File

@@ -6,3 +6,4 @@
// out-of-line implementations.
#include "streaming/messages/stream_message.hh"
#include "streaming/messages/stream_init_message.hh"