Rename from io.netty.transport.* to io.netty.channel.*
This commit is contained in:
parent
983a70805c
commit
201df99ee0
@ -22,8 +22,8 @@ import io.netty.channel.socket.oio.OioEventLoopGroup;
|
||||
import io.netty.handler.codec.LineBasedFrameDecoder;
|
||||
import io.netty.handler.codec.string.StringDecoder;
|
||||
import io.netty.handler.codec.string.StringEncoder;
|
||||
import io.netty.transport.rxtx.RxtxChannel;
|
||||
import io.netty.transport.rxtx.RxtxDeviceAddress;
|
||||
import io.netty.channel.rxtx.RxtxChannel;
|
||||
import io.netty.channel.rxtx.RxtxDeviceAddress;
|
||||
|
||||
/**
|
||||
* Sends one message to a serial device
|
||||
|
@ -23,8 +23,8 @@ import io.netty.example.udt.util.UtilConsoleReporter;
|
||||
import io.netty.example.udt.util.UtilThreadFactory;
|
||||
import io.netty.handler.logging.LogLevel;
|
||||
import io.netty.handler.logging.LoggingHandler;
|
||||
import io.netty.transport.udt.UdtChannel;
|
||||
import io.netty.transport.udt.nio.NioUdtProvider;
|
||||
import io.netty.channel.udt.UdtChannel;
|
||||
import io.netty.channel.udt.nio.NioUdtProvider;
|
||||
|
||||
import java.net.InetSocketAddress;
|
||||
import java.util.concurrent.ThreadFactory;
|
||||
|
@ -20,7 +20,7 @@ import io.netty.buffer.Unpooled;
|
||||
import io.netty.channel.ChannelHandlerContext;
|
||||
import io.netty.channel.ChannelInboundByteHandlerAdapter;
|
||||
import io.netty.channel.ChannelOption;
|
||||
import io.netty.transport.udt.nio.NioUdtProvider;
|
||||
import io.netty.channel.udt.nio.NioUdtProvider;
|
||||
|
||||
import java.util.concurrent.TimeUnit;
|
||||
|
||||
|
@ -23,8 +23,8 @@ import io.netty.channel.socket.nio.NioEventLoopGroup;
|
||||
import io.netty.example.udt.util.UtilThreadFactory;
|
||||
import io.netty.handler.logging.LogLevel;
|
||||
import io.netty.handler.logging.LoggingHandler;
|
||||
import io.netty.transport.udt.UdtChannel;
|
||||
import io.netty.transport.udt.nio.NioUdtProvider;
|
||||
import io.netty.channel.udt.UdtChannel;
|
||||
import io.netty.channel.udt.nio.NioUdtProvider;
|
||||
|
||||
import java.util.concurrent.ThreadFactory;
|
||||
|
||||
|
@ -20,7 +20,7 @@ import io.netty.channel.ChannelHandler.Sharable;
|
||||
import io.netty.channel.ChannelHandlerContext;
|
||||
import io.netty.channel.ChannelInboundByteHandlerAdapter;
|
||||
import io.netty.channel.ChannelOption;
|
||||
import io.netty.transport.udt.nio.NioUdtProvider;
|
||||
import io.netty.channel.udt.nio.NioUdtProvider;
|
||||
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
@ -23,8 +23,8 @@ import io.netty.example.udt.util.UtilConsoleReporter;
|
||||
import io.netty.example.udt.util.UtilThreadFactory;
|
||||
import io.netty.handler.logging.LogLevel;
|
||||
import io.netty.handler.logging.LoggingHandler;
|
||||
import io.netty.transport.udt.UdtChannel;
|
||||
import io.netty.transport.udt.nio.NioUdtProvider;
|
||||
import io.netty.channel.udt.UdtChannel;
|
||||
import io.netty.channel.udt.nio.NioUdtProvider;
|
||||
|
||||
import java.net.InetSocketAddress;
|
||||
import java.util.concurrent.ThreadFactory;
|
||||
|
@ -20,8 +20,8 @@ import io.netty.buffer.MessageBuf;
|
||||
import io.netty.buffer.Unpooled;
|
||||
import io.netty.channel.ChannelHandlerContext;
|
||||
import io.netty.channel.ChannelInboundMessageHandlerAdapter;
|
||||
import io.netty.transport.udt.UdtMessage;
|
||||
import io.netty.transport.udt.nio.NioUdtProvider;
|
||||
import io.netty.channel.udt.UdtMessage;
|
||||
import io.netty.channel.udt.nio.NioUdtProvider;
|
||||
|
||||
import java.util.concurrent.TimeUnit;
|
||||
|
||||
|
@ -23,8 +23,8 @@ import io.netty.channel.socket.nio.NioEventLoopGroup;
|
||||
import io.netty.example.udt.util.UtilThreadFactory;
|
||||
import io.netty.handler.logging.LogLevel;
|
||||
import io.netty.handler.logging.LoggingHandler;
|
||||
import io.netty.transport.udt.UdtChannel;
|
||||
import io.netty.transport.udt.nio.NioUdtProvider;
|
||||
import io.netty.channel.udt.UdtChannel;
|
||||
import io.netty.channel.udt.nio.NioUdtProvider;
|
||||
|
||||
import java.util.concurrent.ThreadFactory;
|
||||
|
||||
|
@ -19,8 +19,8 @@ import io.netty.buffer.MessageBuf;
|
||||
import io.netty.channel.ChannelHandler.Sharable;
|
||||
import io.netty.channel.ChannelHandlerContext;
|
||||
import io.netty.channel.ChannelInboundMessageHandlerAdapter;
|
||||
import io.netty.transport.udt.UdtMessage;
|
||||
import io.netty.transport.udt.nio.NioUdtProvider;
|
||||
import io.netty.channel.udt.UdtMessage;
|
||||
import io.netty.channel.udt.nio.NioUdtProvider;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
|
@ -22,8 +22,8 @@ import io.netty.channel.socket.nio.NioEventLoopGroup;
|
||||
import io.netty.example.udt.util.UtilThreadFactory;
|
||||
import io.netty.handler.logging.LogLevel;
|
||||
import io.netty.handler.logging.LoggingHandler;
|
||||
import io.netty.transport.udt.UdtChannel;
|
||||
import io.netty.transport.udt.nio.NioUdtProvider;
|
||||
import io.netty.channel.udt.UdtChannel;
|
||||
import io.netty.channel.udt.nio.NioUdtProvider;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
|
@ -20,8 +20,8 @@ import io.netty.buffer.MessageBuf;
|
||||
import io.netty.buffer.Unpooled;
|
||||
import io.netty.channel.ChannelHandlerContext;
|
||||
import io.netty.channel.ChannelInboundMessageHandlerAdapter;
|
||||
import io.netty.transport.udt.UdtMessage;
|
||||
import io.netty.transport.udt.nio.NioUdtProvider;
|
||||
import io.netty.channel.udt.UdtMessage;
|
||||
import io.netty.channel.udt.nio.NioUdtProvider;
|
||||
|
||||
import java.util.concurrent.TimeUnit;
|
||||
|
||||
|
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package io.netty.transport.rxtx;
|
||||
package io.netty.channel.rxtx;
|
||||
|
||||
import gnu.io.CommPort;
|
||||
import gnu.io.CommPortIdentifier;
|
||||
@ -30,7 +30,7 @@ import java.net.SocketAddress;
|
||||
import java.net.SocketTimeoutException;
|
||||
import java.nio.channels.NotYetConnectedException;
|
||||
|
||||
import static io.netty.transport.rxtx.RxtxChannelOptions.*;
|
||||
import static io.netty.channel.rxtx.RxtxChannelOptions.*;
|
||||
|
||||
/**
|
||||
* A channel to a serial device using the RXTX library.
|
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package io.netty.transport.rxtx;
|
||||
package io.netty.channel.rxtx;
|
||||
|
||||
import gnu.io.SerialPort;
|
||||
import io.netty.channel.ChannelOption;
|
||||
@ -21,7 +21,7 @@ import io.netty.channel.DefaultChannelConfig;
|
||||
|
||||
import java.util.Map;
|
||||
|
||||
import static io.netty.transport.rxtx.RxtxChannelOptions.*;
|
||||
import static io.netty.channel.rxtx.RxtxChannelOptions.*;
|
||||
|
||||
/**
|
||||
* A configuration class for RXTX device connections.
|
@ -13,12 +13,12 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package io.netty.transport.rxtx;
|
||||
package io.netty.channel.rxtx;
|
||||
|
||||
import io.netty.channel.ChannelOption;
|
||||
import io.netty.transport.rxtx.RxtxChannelConfig.Databits;
|
||||
import io.netty.transport.rxtx.RxtxChannelConfig.Paritybit;
|
||||
import io.netty.transport.rxtx.RxtxChannelConfig.Stopbits;
|
||||
import io.netty.channel.rxtx.RxtxChannelConfig.Databits;
|
||||
import io.netty.channel.rxtx.RxtxChannelConfig.Paritybit;
|
||||
import io.netty.channel.rxtx.RxtxChannelConfig.Stopbits;
|
||||
|
||||
/**
|
||||
* Options for configuring a serial port connection
|
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package io.netty.transport.rxtx;
|
||||
package io.netty.channel.rxtx;
|
||||
|
||||
import java.net.SocketAddress;
|
||||
|
@ -17,4 +17,4 @@
|
||||
/**
|
||||
* A serial and parallel port communication transport based on <a href="http://rxtx.qbang.org/">RXTX</a>.
|
||||
*/
|
||||
package io.netty.transport.rxtx;
|
||||
package io.netty.channel.rxtx;
|
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package io.netty.transport.udt;
|
||||
package io.netty.channel.udt;
|
||||
|
||||
import com.barchart.udt.OptionUDT;
|
||||
import com.barchart.udt.SocketUDT;
|
@ -13,10 +13,10 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package io.netty.transport.udt;
|
||||
package io.netty.channel.udt;
|
||||
|
||||
import io.netty.channel.Channel;
|
||||
import io.netty.transport.udt.nio.NioUdtProvider;
|
||||
import io.netty.channel.udt.nio.NioUdtProvider;
|
||||
|
||||
import java.net.InetSocketAddress;
|
||||
|
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package io.netty.transport.udt;
|
||||
package io.netty.channel.udt;
|
||||
|
||||
import io.netty.channel.ChannelConfig;
|
||||
import io.netty.channel.ChannelException;
|
@ -13,11 +13,11 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package io.netty.transport.udt;
|
||||
package io.netty.channel.udt;
|
||||
|
||||
import io.netty.buffer.ByteBuf;
|
||||
import io.netty.buffer.DefaultByteBufHolder;
|
||||
import io.netty.transport.udt.nio.NioUdtProvider;
|
||||
import io.netty.channel.udt.nio.NioUdtProvider;
|
||||
|
||||
import com.barchart.udt.TypeUDT;
|
||||
|
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package io.netty.transport.udt.nio;
|
||||
package io.netty.channel.udt.nio;
|
||||
|
||||
import static java.nio.channels.SelectionKey.*;
|
||||
import io.netty.buffer.MessageBuf;
|
||||
@ -21,9 +21,9 @@ import io.netty.channel.ChannelException;
|
||||
import io.netty.channel.socket.nio.AbstractNioMessageChannel;
|
||||
import io.netty.logging.InternalLogger;
|
||||
import io.netty.logging.InternalLoggerFactory;
|
||||
import io.netty.transport.udt.DefaultUdtChannelConfig;
|
||||
import io.netty.transport.udt.UdtChannel;
|
||||
import io.netty.transport.udt.UdtChannelConfig;
|
||||
import io.netty.channel.udt.DefaultUdtChannelConfig;
|
||||
import io.netty.channel.udt.UdtChannel;
|
||||
import io.netty.channel.udt.UdtChannelConfig;
|
||||
|
||||
import java.net.InetSocketAddress;
|
||||
import java.net.SocketAddress;
|
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package io.netty.transport.udt.nio;
|
||||
package io.netty.channel.udt.nio;
|
||||
|
||||
import io.netty.buffer.BufType;
|
||||
import io.netty.buffer.MessageBuf;
|
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package io.netty.transport.udt.nio;
|
||||
package io.netty.channel.udt.nio;
|
||||
|
||||
import static java.nio.channels.SelectionKey.*;
|
||||
import io.netty.buffer.BufType;
|
||||
@ -24,9 +24,9 @@ import io.netty.channel.ChannelMetadata;
|
||||
import io.netty.channel.socket.nio.AbstractNioByteChannel;
|
||||
import io.netty.logging.InternalLogger;
|
||||
import io.netty.logging.InternalLoggerFactory;
|
||||
import io.netty.transport.udt.DefaultUdtChannelConfig;
|
||||
import io.netty.transport.udt.UdtChannel;
|
||||
import io.netty.transport.udt.UdtChannelConfig;
|
||||
import io.netty.channel.udt.DefaultUdtChannelConfig;
|
||||
import io.netty.channel.udt.UdtChannel;
|
||||
import io.netty.channel.udt.UdtChannelConfig;
|
||||
|
||||
import java.net.SocketAddress;
|
||||
import java.nio.channels.SelectionKey;
|
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package io.netty.transport.udt.nio;
|
||||
package io.netty.channel.udt.nio;
|
||||
|
||||
import com.barchart.udt.TypeUDT;
|
||||
|
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package io.netty.transport.udt.nio;
|
||||
package io.netty.channel.udt.nio;
|
||||
|
||||
import io.netty.buffer.BufType;
|
||||
import io.netty.buffer.MessageBuf;
|
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package io.netty.transport.udt.nio;
|
||||
package io.netty.channel.udt.nio;
|
||||
|
||||
import static java.nio.channels.SelectionKey.*;
|
||||
import io.netty.buffer.BufType;
|
||||
@ -25,10 +25,10 @@ import io.netty.channel.ChannelMetadata;
|
||||
import io.netty.channel.socket.nio.AbstractNioMessageChannel;
|
||||
import io.netty.logging.InternalLogger;
|
||||
import io.netty.logging.InternalLoggerFactory;
|
||||
import io.netty.transport.udt.DefaultUdtChannelConfig;
|
||||
import io.netty.transport.udt.UdtChannel;
|
||||
import io.netty.transport.udt.UdtChannelConfig;
|
||||
import io.netty.transport.udt.UdtMessage;
|
||||
import io.netty.channel.udt.DefaultUdtChannelConfig;
|
||||
import io.netty.channel.udt.UdtChannel;
|
||||
import io.netty.channel.udt.UdtChannelConfig;
|
||||
import io.netty.channel.udt.UdtMessage;
|
||||
|
||||
import java.net.SocketAddress;
|
||||
import java.nio.channels.SelectionKey;
|
@ -13,10 +13,10 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package io.netty.transport.udt.nio;
|
||||
package io.netty.channel.udt.nio;
|
||||
|
||||
import com.barchart.udt.TypeUDT;
|
||||
import io.netty.transport.udt.UdtMessage;
|
||||
import io.netty.channel.udt.UdtMessage;
|
||||
|
||||
/**
|
||||
* Message Rendezvous for UDT Datagrams.
|
@ -13,14 +13,14 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package io.netty.transport.udt.nio;
|
||||
package io.netty.channel.udt.nio;
|
||||
|
||||
import io.netty.bootstrap.AbstractBootstrap.ChannelFactory;
|
||||
import io.netty.channel.Channel;
|
||||
import io.netty.channel.ChannelException;
|
||||
import io.netty.logging.InternalLogger;
|
||||
import io.netty.logging.InternalLoggerFactory;
|
||||
import io.netty.transport.udt.UdtChannel;
|
||||
import io.netty.channel.udt.UdtChannel;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.nio.channels.spi.SelectorProvider;
|
@ -18,5 +18,5 @@
|
||||
* <p>
|
||||
* @see /netty/example/src/main/java/io/netty/example/udt
|
||||
*/
|
||||
package io.netty.transport.udt.nio;
|
||||
package io.netty.channel.udt.nio;
|
||||
|
@ -18,5 +18,5 @@
|
||||
* <p>
|
||||
* @see /netty/example/src/main/java/io/netty/example/udt
|
||||
*/
|
||||
package io.netty.transport.udt.oio;
|
||||
package io.netty.channel.udt.oio;
|
||||
|
@ -18,5 +18,5 @@
|
||||
* <p>
|
||||
* @see /netty/example/src/main/java/io/netty/example/udt
|
||||
*/
|
||||
package io.netty.transport.udt;
|
||||
package io.netty.channel.udt;
|
||||
|
@ -14,11 +14,11 @@
|
||||
* under the License.
|
||||
*/
|
||||
|
||||
package io.netty.transport.udt.bench;
|
||||
package io.netty.channel.udt.bench;
|
||||
|
||||
import io.netty.transport.udt.util.CaliperBench;
|
||||
import io.netty.transport.udt.util.CaliperRunner;
|
||||
import io.netty.transport.udt.util.TrafficControl;
|
||||
import io.netty.channel.udt.util.CaliperBench;
|
||||
import io.netty.channel.udt.util.CaliperRunner;
|
||||
import io.netty.channel.udt.util.TrafficControl;
|
||||
|
||||
import java.util.List;
|
||||
|
@ -17,5 +17,5 @@
|
||||
/**
|
||||
* UDT Benchmarks
|
||||
*/
|
||||
package io.netty.transport.udt.bench;
|
||||
package io.netty.channel.udt.bench;
|
||||
|
@ -14,11 +14,11 @@
|
||||
* under the License.
|
||||
*/
|
||||
|
||||
package io.netty.transport.udt.bench.xfer;
|
||||
package io.netty.channel.udt.bench.xfer;
|
||||
|
||||
import io.netty.transport.udt.bench.BenchXfer;
|
||||
import io.netty.transport.udt.util.CaliperRunner;
|
||||
import io.netty.transport.udt.util.TrafficControl;
|
||||
import io.netty.channel.udt.bench.BenchXfer;
|
||||
import io.netty.channel.udt.util.CaliperRunner;
|
||||
import io.netty.channel.udt.util.TrafficControl;
|
||||
|
||||
import java.util.List;
|
||||
|
@ -14,15 +14,15 @@
|
||||
* under the License.
|
||||
*/
|
||||
|
||||
package io.netty.transport.udt.bench.xfer;
|
||||
package io.netty.channel.udt.bench.xfer;
|
||||
|
||||
import com.barchart.udt.SocketUDT;
|
||||
import com.barchart.udt.StatusUDT;
|
||||
import com.barchart.udt.TypeUDT;
|
||||
import com.google.caliper.Param;
|
||||
import io.netty.transport.udt.bench.BenchXfer;
|
||||
import io.netty.transport.udt.util.CaliperRunner;
|
||||
import io.netty.transport.udt.util.TrafficControl;
|
||||
import io.netty.channel.udt.bench.BenchXfer;
|
||||
import io.netty.channel.udt.util.CaliperRunner;
|
||||
import io.netty.channel.udt.util.TrafficControl;
|
||||
|
||||
import java.net.InetSocketAddress;
|
||||
import java.nio.ByteBuffer;
|
||||
@ -32,7 +32,7 @@ import java.util.concurrent.ExecutorService;
|
||||
import java.util.concurrent.Executors;
|
||||
import java.util.concurrent.atomic.AtomicBoolean;
|
||||
|
||||
import static io.netty.transport.udt.util.UnitHelp.*;
|
||||
import static io.netty.channel.udt.util.UnitHelp.*;
|
||||
|
||||
/**
|
||||
* perform two way native UDT socket send/recv
|
@ -14,7 +14,7 @@
|
||||
* under the License.
|
||||
*/
|
||||
|
||||
package io.netty.transport.udt.bench.xfer;
|
||||
package io.netty.channel.udt.bench.xfer;
|
||||
|
||||
import com.yammer.metrics.Metrics;
|
||||
import com.yammer.metrics.core.Counter;
|
||||
@ -24,11 +24,11 @@ import io.netty.channel.ChannelFuture;
|
||||
import io.netty.channel.ChannelHandler;
|
||||
import io.netty.logging.InternalLoggerFactory;
|
||||
import io.netty.logging.Slf4JLoggerFactory;
|
||||
import io.netty.transport.udt.util.BootHelp;
|
||||
import io.netty.transport.udt.util.CustomReporter;
|
||||
import io.netty.transport.udt.util.EchoMessageHandler;
|
||||
import io.netty.transport.udt.util.TrafficControl;
|
||||
import io.netty.transport.udt.util.UnitHelp;
|
||||
import io.netty.channel.udt.util.BootHelp;
|
||||
import io.netty.channel.udt.util.CustomReporter;
|
||||
import io.netty.channel.udt.util.EchoMessageHandler;
|
||||
import io.netty.channel.udt.util.TrafficControl;
|
||||
import io.netty.channel.udt.util.UnitHelp;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
@ -17,5 +17,5 @@
|
||||
/**
|
||||
* UDT Transfer Speed Benchmarks
|
||||
*/
|
||||
package io.netty.transport.udt.bench.xfer;
|
||||
package io.netty.channel.udt.bench.xfer;
|
||||
|
@ -14,7 +14,7 @@
|
||||
* under the License.
|
||||
*/
|
||||
|
||||
package io.netty.transport.udt.nio;
|
||||
package io.netty.channel.udt.nio;
|
||||
|
||||
import io.netty.buffer.BufType;
|
||||
import org.junit.Test;
|
@ -14,7 +14,7 @@
|
||||
* under the License.
|
||||
*/
|
||||
|
||||
package io.netty.transport.udt.nio;
|
||||
package io.netty.channel.udt.nio;
|
||||
|
||||
import io.netty.buffer.BufType;
|
||||
import org.junit.Test;
|
@ -14,16 +14,16 @@
|
||||
* under the License.
|
||||
*/
|
||||
|
||||
package io.netty.transport.udt.nio;
|
||||
package io.netty.channel.udt.nio;
|
||||
|
||||
import com.yammer.metrics.Metrics;
|
||||
import com.yammer.metrics.core.Meter;
|
||||
import io.netty.bootstrap.Bootstrap;
|
||||
import io.netty.buffer.BufType;
|
||||
import io.netty.channel.ChannelFuture;
|
||||
import io.netty.transport.udt.util.BootHelp;
|
||||
import io.netty.transport.udt.util.EchoByteHandler;
|
||||
import io.netty.transport.udt.util.UnitHelp;
|
||||
import io.netty.channel.udt.util.BootHelp;
|
||||
import io.netty.channel.udt.util.EchoByteHandler;
|
||||
import io.netty.channel.udt.util.UnitHelp;
|
||||
import org.junit.Test;
|
||||
|
||||
import java.net.InetSocketAddress;
|
@ -14,7 +14,7 @@
|
||||
* under the License.
|
||||
*/
|
||||
|
||||
package io.netty.transport.udt.nio;
|
||||
package io.netty.channel.udt.nio;
|
||||
|
||||
import io.netty.buffer.BufType;
|
||||
import org.junit.Test;
|
@ -14,7 +14,7 @@
|
||||
* under the License.
|
||||
*/
|
||||
|
||||
package io.netty.transport.udt.nio;
|
||||
package io.netty.channel.udt.nio;
|
||||
|
||||
import io.netty.buffer.BufType;
|
||||
import org.junit.Test;
|
@ -14,16 +14,16 @@
|
||||
* under the License.
|
||||
*/
|
||||
|
||||
package io.netty.transport.udt.nio;
|
||||
package io.netty.channel.udt.nio;
|
||||
|
||||
import com.yammer.metrics.Metrics;
|
||||
import com.yammer.metrics.core.Meter;
|
||||
import io.netty.bootstrap.Bootstrap;
|
||||
import io.netty.buffer.BufType;
|
||||
import io.netty.channel.ChannelFuture;
|
||||
import io.netty.transport.udt.util.BootHelp;
|
||||
import io.netty.transport.udt.util.EchoMessageHandler;
|
||||
import io.netty.transport.udt.util.UnitHelp;
|
||||
import io.netty.channel.udt.util.BootHelp;
|
||||
import io.netty.channel.udt.util.EchoMessageHandler;
|
||||
import io.netty.channel.udt.util.UnitHelp;
|
||||
import org.junit.Test;
|
||||
|
||||
import java.net.InetSocketAddress;
|
@ -14,7 +14,7 @@
|
||||
* under the License.
|
||||
*/
|
||||
|
||||
package io.netty.transport.udt.nio;
|
||||
package io.netty.channel.udt.nio;
|
||||
|
||||
import org.junit.Test;
|
||||
|
@ -14,7 +14,7 @@
|
||||
* under the License.
|
||||
*/
|
||||
|
||||
package io.netty.transport.udt.nio;
|
||||
package io.netty.channel.udt.nio;
|
||||
|
||||
import io.netty.logging.InternalLoggerFactory;
|
||||
import io.netty.logging.Slf4JLoggerFactory;
|
@ -14,12 +14,12 @@
|
||||
* under the License.
|
||||
*/
|
||||
|
||||
package io.netty.transport.udt.util;
|
||||
package io.netty.channel.udt.util;
|
||||
|
||||
import io.netty.bootstrap.Bootstrap;
|
||||
import io.netty.channel.ChannelHandler;
|
||||
import io.netty.channel.socket.nio.NioEventLoopGroup;
|
||||
import io.netty.transport.udt.nio.NioUdtProvider;
|
||||
import io.netty.channel.udt.nio.NioUdtProvider;
|
||||
|
||||
import java.net.InetSocketAddress;
|
||||
import java.util.concurrent.ThreadFactory;
|
@ -14,7 +14,7 @@
|
||||
* under the License.
|
||||
*/
|
||||
|
||||
package io.netty.transport.udt.util;
|
||||
package io.netty.channel.udt.util;
|
||||
|
||||
import io.netty.logging.InternalLoggerFactory;
|
||||
import io.netty.logging.Slf4JLoggerFactory;
|
@ -14,7 +14,7 @@
|
||||
* under the License.
|
||||
*/
|
||||
|
||||
package io.netty.transport.udt.util;
|
||||
package io.netty.channel.udt.util;
|
||||
|
||||
import com.google.caliper.Measurement;
|
||||
import com.google.caliper.MeasurementSet;
|
@ -15,7 +15,7 @@
|
||||
* under the License.
|
||||
*/
|
||||
|
||||
package io.netty.transport.udt.util;
|
||||
package io.netty.channel.udt.util;
|
||||
|
||||
import com.google.caliper.ConfiguredBenchmark;
|
||||
import com.google.caliper.Environment;
|
@ -14,7 +14,7 @@
|
||||
* under the License.
|
||||
*/
|
||||
|
||||
package io.netty.transport.udt.util;
|
||||
package io.netty.channel.udt.util;
|
||||
|
||||
import com.yammer.metrics.Metrics;
|
||||
import com.yammer.metrics.core.Clock;
|
@ -14,14 +14,14 @@
|
||||
* under the License.
|
||||
*/
|
||||
|
||||
package io.netty.transport.udt.util;
|
||||
package io.netty.channel.udt.util;
|
||||
|
||||
import io.netty.buffer.ByteBuf;
|
||||
import io.netty.buffer.Unpooled;
|
||||
import io.netty.channel.ChannelHandlerContext;
|
||||
import io.netty.channel.ChannelInboundByteHandlerAdapter;
|
||||
import io.netty.channel.ChannelOption;
|
||||
import io.netty.transport.udt.nio.NioUdtProvider;
|
||||
import io.netty.channel.udt.nio.NioUdtProvider;
|
||||
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
@ -14,7 +14,7 @@
|
||||
* under the License.
|
||||
*/
|
||||
|
||||
package io.netty.transport.udt.util;
|
||||
package io.netty.channel.udt.util;
|
||||
|
||||
import com.yammer.metrics.core.Meter;
|
||||
import io.netty.buffer.ByteBuf;
|
||||
@ -22,8 +22,8 @@ import io.netty.buffer.MessageBuf;
|
||||
import io.netty.buffer.Unpooled;
|
||||
import io.netty.channel.ChannelHandlerContext;
|
||||
import io.netty.channel.ChannelInboundMessageHandlerAdapter;
|
||||
import io.netty.transport.udt.UdtMessage;
|
||||
import io.netty.transport.udt.nio.NioUdtProvider;
|
||||
import io.netty.channel.udt.UdtMessage;
|
||||
import io.netty.channel.udt.nio.NioUdtProvider;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
@ -14,7 +14,7 @@
|
||||
* under the License.
|
||||
*/
|
||||
|
||||
package io.netty.transport.udt.util;
|
||||
package io.netty.channel.udt.util;
|
||||
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
@ -14,7 +14,7 @@
|
||||
* under the License.
|
||||
*/
|
||||
|
||||
package io.netty.transport.udt.util;
|
||||
package io.netty.channel.udt.util;
|
||||
|
||||
import com.barchart.udt.SocketUDT;
|
||||
import com.barchart.udt.StatusUDT;
|
@ -14,7 +14,7 @@
|
||||
* under the License.
|
||||
*/
|
||||
|
||||
package io.netty.transport.udt.util;
|
||||
package io.netty.channel.udt.util;
|
||||
|
||||
import java.util.concurrent.ThreadFactory;
|
||||
import java.util.concurrent.atomic.AtomicInteger;
|
@ -17,5 +17,5 @@
|
||||
/**
|
||||
* UDT Benchmarks and Tests Utilities
|
||||
*/
|
||||
package io.netty.transport.udt.util;
|
||||
package io.netty.channel.udt.util;
|
||||
|
Loading…
Reference in New Issue
Block a user