8003ea8a03
Motivation: We should update to use junit5 in all modules. Modifications: Adjust transport-udt tests to use junit5 Result: Part of https://github.com/netty/netty/issues/10757
126 lines
4.5 KiB
Java
126 lines
4.5 KiB
Java
/*
|
|
* 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:
|
|
*
|
|
* https://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.test.udt.nio;
|
|
|
|
import com.yammer.metrics.Metrics;
|
|
import com.yammer.metrics.core.Meter;
|
|
import io.netty.bootstrap.Bootstrap;
|
|
import io.netty.channel.ChannelFuture;
|
|
import io.netty.channel.nio.NioEventLoopGroup;
|
|
import io.netty.channel.udt.nio.NioUdtByteRendezvousChannel;
|
|
import io.netty.channel.udt.nio.NioUdtProvider;
|
|
import io.netty.test.udt.util.EchoByteHandler;
|
|
import io.netty.test.udt.util.UnitHelp;
|
|
import io.netty.util.internal.logging.InternalLogger;
|
|
import io.netty.util.internal.logging.InternalLoggerFactory;
|
|
import org.junit.jupiter.api.Test;
|
|
import org.junit.jupiter.api.Timeout;
|
|
|
|
import java.net.InetSocketAddress;
|
|
import java.util.concurrent.Executors;
|
|
import java.util.concurrent.TimeUnit;
|
|
|
|
import static org.junit.jupiter.api.Assertions.assertEquals;
|
|
import static org.junit.jupiter.api.Assertions.assertFalse;
|
|
import static org.junit.jupiter.api.Assertions.assertTrue;
|
|
|
|
public class NioUdtByteRendezvousChannelTest extends AbstractUdtTest {
|
|
|
|
private static final InternalLogger log = InternalLoggerFactory.getInstance(NioUdtByteAcceptorChannelTest.class);
|
|
|
|
/**
|
|
* verify channel meta data
|
|
*/
|
|
@Test
|
|
public void metadata() throws Exception {
|
|
assertFalse(new NioUdtByteRendezvousChannel().metadata().hasDisconnect());
|
|
}
|
|
|
|
/**
|
|
* verify basic echo byte rendezvous
|
|
*/
|
|
@Test
|
|
@Timeout(value = 10000, unit = TimeUnit.MILLISECONDS)
|
|
public void basicEcho() throws Exception {
|
|
|
|
final int messageSize = 64 * 1024;
|
|
final int transferLimit = messageSize * 16;
|
|
|
|
final Meter rate1 = Metrics.newMeter(
|
|
NioUdtMessageRendezvousChannelTest.class, "send rate", "bytes",
|
|
TimeUnit.SECONDS);
|
|
|
|
final Meter rate2 = Metrics.newMeter(
|
|
NioUdtMessageRendezvousChannelTest.class, "send rate", "bytes",
|
|
TimeUnit.SECONDS);
|
|
|
|
final InetSocketAddress addr1 = UnitHelp.localSocketAddress();
|
|
final InetSocketAddress addr2 = UnitHelp.localSocketAddress();
|
|
|
|
final EchoByteHandler handler1 = new EchoByteHandler(rate1, messageSize);
|
|
final EchoByteHandler handler2 = new EchoByteHandler(rate2, messageSize);
|
|
|
|
final NioEventLoopGroup group1 = new NioEventLoopGroup(
|
|
1, Executors.defaultThreadFactory(), NioUdtProvider.BYTE_PROVIDER);
|
|
final NioEventLoopGroup group2 = new NioEventLoopGroup(
|
|
1, Executors.defaultThreadFactory(), NioUdtProvider.BYTE_PROVIDER);
|
|
|
|
final Bootstrap boot1 = new Bootstrap();
|
|
boot1.group(group1)
|
|
.channelFactory(NioUdtProvider.BYTE_RENDEZVOUS)
|
|
.localAddress(addr1)
|
|
.remoteAddress(addr2)
|
|
.handler(handler1);
|
|
|
|
final Bootstrap boot2 = new Bootstrap();
|
|
boot2.group(group1)
|
|
.channelFactory(NioUdtProvider.BYTE_RENDEZVOUS)
|
|
.localAddress(addr2)
|
|
.remoteAddress(addr1)
|
|
.handler(handler2);
|
|
|
|
final ChannelFuture connectFuture1 = boot1.connect();
|
|
final ChannelFuture connectFuture2 = boot2.connect();
|
|
|
|
while (handler1.meter().count() < transferLimit
|
|
&& handler2.meter().count() < transferLimit) {
|
|
|
|
log.info("progress : {} {}", handler1.meter().count(), handler2
|
|
.meter().count());
|
|
|
|
Thread.sleep(1000);
|
|
}
|
|
|
|
connectFuture1.channel().close().sync();
|
|
connectFuture2.channel().close().sync();
|
|
|
|
log.info("handler1 : {}", handler1.meter().count());
|
|
log.info("handler2 : {}", handler2.meter().count());
|
|
|
|
assertTrue(handler1.meter().count() >= transferLimit);
|
|
assertTrue(handler2.meter().count() >= transferLimit);
|
|
|
|
assertEquals(handler1.meter().count(), handler2.meter().count());
|
|
|
|
group1.shutdownGracefully();
|
|
group2.shutdownGracefully();
|
|
|
|
group1.terminationFuture().sync();
|
|
group2.terminationFuture().sync();
|
|
}
|
|
}
|