- * Sends one message when a connection is open and echoes back any received data
- * to the server. Simply put, the echo client initiates the ping-pong traffic
- * between the echo client and server by sending the first message to the
- * server.
- */
-public final class ByteEchoClient {
-
- static final String HOST = System.getProperty("host", "127.0.0.1");
- static final int PORT = Integer.parseInt(System.getProperty("port", "8007"));
- static final int SIZE = Integer.parseInt(System.getProperty("size", "256"));
-
- public static void main(String[] args) throws Exception {
- // Configure the client.
- final ThreadFactory connectFactory = new DefaultThreadFactory("connect");
- final NioEventLoopGroup connectGroup = new NioEventLoopGroup(1,
- connectFactory, NioUdtProvider.BYTE_PROVIDER);
- try {
- final Bootstrap boot = new Bootstrap();
- boot.group(connectGroup)
- .channelFactory(NioUdtProvider.BYTE_CONNECTOR)
- .handler(new ChannelInitializer
- * Echoes back any received data from a client.
- */
-public final class ByteEchoServer {
-
- static final int PORT = Integer.parseInt(System.getProperty("port", "8007"));
-
- public static void main(String[] args) throws Exception {
- final ThreadFactory acceptFactory = new DefaultThreadFactory("accept");
- final ThreadFactory connectFactory = new DefaultThreadFactory("connect");
- final NioEventLoopGroup acceptGroup = new NioEventLoopGroup(1, acceptFactory, NioUdtProvider.BYTE_PROVIDER);
- final NioEventLoopGroup connectGroup = new NioEventLoopGroup(1, connectFactory, NioUdtProvider.BYTE_PROVIDER);
-
- // Configure the server.
- try {
- final ServerBootstrap boot = new ServerBootstrap();
- boot.group(acceptGroup, connectGroup)
- .channelFactory(NioUdtProvider.BYTE_ACCEPTOR)
- .option(ChannelOption.SO_BACKLOG, 10)
- .handler(new LoggingHandler(LogLevel.INFO))
- .childHandler(new ChannelInitializer
- * Sends one message when a connection is open and echoes back any received data
- * to the server. Simply put, the echo client initiates the ping-pong traffic
- * between the echo client and server by sending the first message to the
- * server.
- */
-public final class MsgEchoClient {
-
- private static final Logger log = Logger.getLogger(MsgEchoClient.class.getName());
-
- static final String HOST = System.getProperty("host", "127.0.0.1");
- static final int PORT = Integer.parseInt(System.getProperty("port", "8007"));
- static final int SIZE = Integer.parseInt(System.getProperty("size", "256"));
-
- public static void main(String[] args) throws Exception {
-
- // Configure the client.
- final ThreadFactory connectFactory = new DefaultThreadFactory("connect");
- final NioEventLoopGroup connectGroup = new NioEventLoopGroup(1,
- connectFactory, NioUdtProvider.MESSAGE_PROVIDER);
- try {
- final Bootstrap boot = new Bootstrap();
- boot.group(connectGroup)
- .channelFactory(NioUdtProvider.MESSAGE_CONNECTOR)
- .handler(new ChannelInitializer
- * Echoes back any received data from a client.
- */
-public final class MsgEchoServer {
-
- static final int PORT = Integer.parseInt(System.getProperty("port", "8007"));
-
- public static void main(String[] args) throws Exception {
- final ThreadFactory acceptFactory = new DefaultThreadFactory("accept");
- final ThreadFactory connectFactory = new DefaultThreadFactory("connect");
- final NioEventLoopGroup acceptGroup =
- new NioEventLoopGroup(1, acceptFactory, NioUdtProvider.MESSAGE_PROVIDER);
- final NioEventLoopGroup connectGroup =
- new NioEventLoopGroup(1, connectFactory, NioUdtProvider.MESSAGE_PROVIDER);
-
- // Configure the server.
- try {
- final ServerBootstrap boot = new ServerBootstrap();
- boot.group(acceptGroup, connectGroup)
- .channelFactory(NioUdtProvider.MESSAGE_ACCEPTOR)
- .option(ChannelOption.SO_BACKLOG, 10)
- .handler(new LoggingHandler(LogLevel.INFO))
- .childHandler(new ChannelInitializer
- * Sends one message when a connection is open and echoes back any received data
- * to the other peer.
- */
-public abstract class MsgEchoPeerBase {
-
- protected final int messageSize;
- protected final InetSocketAddress self;
- protected final InetSocketAddress peer;
-
- protected MsgEchoPeerBase(final InetSocketAddress self, final InetSocketAddress peer, final int messageSize) {
- this.messageSize = messageSize;
- this.self = self;
- this.peer = peer;
- }
-
- public void run() throws Exception {
- // Configure the peer.
- final ThreadFactory connectFactory = new DefaultThreadFactory("rendezvous");
- final NioEventLoopGroup connectGroup = new NioEventLoopGroup(1,
- connectFactory, NioUdtProvider.MESSAGE_PROVIDER);
- try {
- final Bootstrap boot = new Bootstrap();
- boot.group(connectGroup)
- .channelFactory(NioUdtProvider.MESSAGE_RENDEZVOUS)
- .handler(new ChannelInitializer
- * Sends one message when a connection is open and echoes back any received data
- * to the other peer.
- */
-public class MsgEchoPeerOne extends MsgEchoPeerBase {
-
- public MsgEchoPeerOne(final InetSocketAddress self, final InetSocketAddress peer, final int messageSize) {
- super(self, peer, messageSize);
- }
-
- public static void main(final String[] args) throws Exception {
- final int messageSize = 64 * 1024;
- final InetSocketAddress self = SocketUtils.socketAddress(Config.hostOne, Config.portOne);
- final InetSocketAddress peer = SocketUtils.socketAddress(Config.hostTwo, Config.portTwo);
- new MsgEchoPeerOne(self, peer, messageSize).run();
- }
-}
diff --git a/example/src/main/java/io/netty/example/udt/echo/rendezvous/MsgEchoPeerTwo.java b/example/src/main/java/io/netty/example/udt/echo/rendezvous/MsgEchoPeerTwo.java
deleted file mode 100644
index 84012e6f35..0000000000
--- a/example/src/main/java/io/netty/example/udt/echo/rendezvous/MsgEchoPeerTwo.java
+++ /dev/null
@@ -1,40 +0,0 @@
-/*
- * Copyright 2012 The Netty Project
- *
- * The Netty Project licenses this file to you under the Apache License,
- * version 2.0 (the "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at:
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS, 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.
- */
-package io.netty.example.udt.echo.rendezvous;
-
-import io.netty.util.internal.SocketUtils;
-
-import java.net.InetSocketAddress;
-
-/**
- * UDT Message Flow Peer
- *
- * Sends one message when a connection is open and echoes back any received data
- * to the other peer.
- */
-public class MsgEchoPeerTwo extends MsgEchoPeerBase {
-
- public MsgEchoPeerTwo(final InetSocketAddress self, final InetSocketAddress peer, final int messageSize) {
- super(self, peer, messageSize);
- }
-
- public static void main(final String[] args) throws Exception {
- final int messageSize = 64 * 1024;
- final InetSocketAddress self = SocketUtils.socketAddress(Config.hostTwo, Config.portTwo);
- final InetSocketAddress peer = SocketUtils.socketAddress(Config.hostOne, Config.portOne);
- new MsgEchoPeerTwo(self, peer, messageSize).run();
- }
-}
diff --git a/example/src/main/java/io/netty/example/udt/echo/rendezvous/package-info.java b/example/src/main/java/io/netty/example/udt/echo/rendezvous/package-info.java
deleted file mode 100644
index 405d85e452..0000000000
--- a/example/src/main/java/io/netty/example/udt/echo/rendezvous/package-info.java
+++ /dev/null
@@ -1,21 +0,0 @@
-/*
- * Copyright 2012 The Netty Project
- *
- * The Netty Project licenses this file to you under the Apache License,
- * version 2.0 (the "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at:
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS, 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.
- */
-
-/**
- * Examples show how to use UDT Message Rendezvous.
- */
-package io.netty.example.udt.echo.rendezvous;
-
diff --git a/example/src/main/java/io/netty/example/udt/echo/rendezvousBytes/ByteEchoPeerBase.java b/example/src/main/java/io/netty/example/udt/echo/rendezvousBytes/ByteEchoPeerBase.java
deleted file mode 100644
index 55d857d9b5..0000000000
--- a/example/src/main/java/io/netty/example/udt/echo/rendezvousBytes/ByteEchoPeerBase.java
+++ /dev/null
@@ -1,74 +0,0 @@
-/*
- * Copyright 2012 The Netty Project
- *
- * The Netty Project licenses this file to you under the Apache License,
- * version 2.0 (the "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at:
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS, 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.
- */
-package io.netty.example.udt.echo.rendezvousBytes;
-
-import io.netty.bootstrap.Bootstrap;
-import io.netty.channel.ChannelFuture;
-import io.netty.channel.ChannelInitializer;
-import io.netty.channel.nio.NioEventLoopGroup;
-import io.netty.channel.udt.UdtChannel;
-import io.netty.channel.udt.nio.NioUdtProvider;
-import io.netty.handler.logging.LogLevel;
-import io.netty.handler.logging.LoggingHandler;
-import io.netty.util.concurrent.DefaultThreadFactory;
-
-import java.net.SocketAddress;
-import java.util.concurrent.ThreadFactory;
-
-/**
- * UDT Byte Stream Peer
- *