|
Java example source code file (EpollSocketChannelTest.java)
The EpollSocketChannelTest.java Java example source code/* * Copyright 2014 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.channel.epoll; import io.netty.bootstrap.Bootstrap; import io.netty.bootstrap.ServerBootstrap; import io.netty.buffer.Unpooled; import io.netty.channel.Channel; import io.netty.channel.ChannelHandlerContext; import io.netty.channel.ChannelInboundHandlerAdapter; import io.netty.channel.ChannelInitializer; import io.netty.channel.ChannelOption; import io.netty.channel.ChannelPipeline; import io.netty.channel.EventLoopGroup; import io.netty.channel.ServerChannel; import io.netty.util.ReferenceCountUtil; import org.junit.Assert; import org.junit.Test; import java.net.InetSocketAddress; import java.net.SocketAddress; import java.util.concurrent.CountDownLatch; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicLong; import static org.junit.Assert.assertFalse; import static org.junit.Assert.assertTrue; public class EpollSocketChannelTest { @Test public void testTcpInfo() throws Exception { EventLoopGroup group = new EpollEventLoopGroup(1); try { Bootstrap bootstrap = new Bootstrap(); EpollSocketChannel ch = (EpollSocketChannel) bootstrap.group(group) .channel(EpollSocketChannel.class) .handler(new ChannelInboundHandlerAdapter()) .bind(new InetSocketAddress(0)).syncUninterruptibly().channel(); EpollTcpInfo info = ch.tcpInfo(); assertTcpInfo0(info); ch.close().syncUninterruptibly(); } finally { group.shutdownGracefully(); } } @Test public void testTcpInfoReuse() throws Exception { EventLoopGroup group = new EpollEventLoopGroup(1); try { Bootstrap bootstrap = new Bootstrap(); EpollSocketChannel ch = (EpollSocketChannel) bootstrap.group(group) .channel(EpollSocketChannel.class) .handler(new ChannelInboundHandlerAdapter()) .bind(new InetSocketAddress(0)).syncUninterruptibly().channel(); EpollTcpInfo info = new EpollTcpInfo(); ch.tcpInfo(info); assertTcpInfo0(info); ch.close().syncUninterruptibly(); } finally { group.shutdownGracefully(); } } private static void assertTcpInfo0(EpollTcpInfo info) throws Exception { Assert.assertNotNull(info); Assert.assertTrue(info.state() >= 0); Assert.assertTrue(info.caState() >= 0); Assert.assertTrue(info.retransmits() >= 0); Assert.assertTrue(info.probes() >= 0); Assert.assertTrue(info.backoff() >= 0); Assert.assertTrue(info.options() >= 0); Assert.assertTrue(info.sndWscale() >= 0); Assert.assertTrue(info.rcvWscale() >= 0); Assert.assertTrue(info.rto() >= 0); Assert.assertTrue(info.ato() >= 0); Assert.assertTrue(info.sndMss() >= 0); Assert.assertTrue(info.rcvMss() >= 0); Assert.assertTrue(info.unacked() >= 0); Assert.assertTrue(info.sacked() >= 0); Assert.assertTrue(info.lost() >= 0); Assert.assertTrue(info.retrans() >= 0); Assert.assertTrue(info.fackets() >= 0); Assert.assertTrue(info.lastDataSent() >= 0); Assert.assertTrue(info.lastAckSent() >= 0); Assert.assertTrue(info.lastDataRecv() >= 0); Assert.assertTrue(info.lastAckRecv() >= 0); Assert.assertTrue(info.pmtu() >= 0); Assert.assertTrue(info.rcvSsthresh() >= 0); Assert.assertTrue(info.rtt() >= 0); Assert.assertTrue(info.rttvar() >= 0); Assert.assertTrue(info.sndSsthresh() >= 0); Assert.assertTrue(info.sndCwnd() >= 0); Assert.assertTrue(info.advmss() >= 0); Assert.assertTrue(info.reordering() >= 0); Assert.assertTrue(info.rcvRtt() >= 0); Assert.assertTrue(info.rcvSpace() >= 0); Assert.assertTrue(info.totalRetrans() >= 0); } } Other Java examples (source code examples)Here is a short list of links related to this Java EpollSocketChannelTest.java source code file: |
... this post is sponsored by my books ... | |
#1 New Release! |
FP Best Seller |
Copyright 1998-2021 Alvin Alexander, alvinalexander.com
All Rights Reserved.
A percentage of advertising revenue from
pages under the /java/jwarehouse
URI on this website is
paid back to open source projects.