public abstract class DatagramUnicastTest extends AbstractDatagramTest
限定符和类型 | 类和说明 |
---|---|
protected static class |
DatagramUnicastTest.WrapType |
AbstractComboTestsuiteTest.Runner<SB extends AbstractBootstrap<?,?>,CB extends AbstractBootstrap<?,?>>
cb, logger, sb
构造器和说明 |
---|
DatagramUnicastTest() |
限定符和类型 | 方法和说明 |
---|---|
protected static void |
closeChannel(Channel channel) |
protected boolean |
disconnectMightFail(DatagramChannel channel) |
protected abstract boolean |
isConnected(Channel channel) |
protected java.net.InetSocketAddress |
sendToAddress(java.net.InetSocketAddress serverAddress) |
protected abstract Channel |
setupClientChannel(Bootstrap cb,
byte[] bytes,
java.util.concurrent.CountDownLatch latch,
java.util.concurrent.atomic.AtomicReference<java.lang.Throwable> errorRef) |
protected abstract Channel |
setupServerChannel(Bootstrap sb,
byte[] bytes,
java.net.SocketAddress sender,
java.util.concurrent.CountDownLatch latch,
java.util.concurrent.atomic.AtomicReference<java.lang.Throwable> errorRef,
boolean echo) |
protected abstract boolean |
supportDisconnect() |
void |
testReceiveEmptyDatagrams(Bootstrap sb,
Bootstrap cb) |
void |
testReceiveEmptyDatagrams(TestInfo testInfo) |
void |
testSendToUnresolvableAddress(Bootstrap sb,
Bootstrap cb) |
void |
testSendToUnresolvableAddress(TestInfo testInfo) |
void |
testSimpleSendCompositeDirectByteBuf(Bootstrap sb,
Bootstrap cb) |
void |
testSimpleSendCompositeDirectByteBuf(TestInfo testInfo) |
void |
testSimpleSendCompositeHeapByteBuf(Bootstrap sb,
Bootstrap cb) |
void |
testSimpleSendCompositeHeapByteBuf(TestInfo testInfo) |
void |
testSimpleSendCompositeMixedByteBuf(Bootstrap sb,
Bootstrap cb) |
void |
testSimpleSendCompositeMixedByteBuf(TestInfo testInfo) |
void |
testSimpleSendDirectByteBuf(Bootstrap sb,
Bootstrap cb) |
void |
testSimpleSendDirectByteBuf(TestInfo testInfo) |
void |
testSimpleSendHeapByteBuf(Bootstrap sb,
Bootstrap cb) |
void |
testSimpleSendHeapByteBuf(TestInfo testInfo) |
void |
testSimpleSendWithConnect(Bootstrap sb,
Bootstrap cb) |
void |
testSimpleSendWithConnect(TestInfo testInfo) |
void |
testSimpleSendWithoutBind(Bootstrap sb,
Bootstrap cb) |
void |
testSimpleSendWithoutBind(TestInfo testInfo) |
protected abstract ChannelFuture |
write(Channel cc,
ByteBuf buf,
java.net.SocketAddress remote,
DatagramUnicastTest.WrapType wrapType) |
configure, groupInternetProtocalFamily, internetProtocolFamily, newFactories, newSocketAddress, socketInternetProtocalFamily
newAllocators, run
public void testSimpleSendDirectByteBuf(TestInfo testInfo) throws java.lang.Throwable
java.lang.Throwable
public void testSimpleSendDirectByteBuf(Bootstrap sb, Bootstrap cb) throws java.lang.Throwable
java.lang.Throwable
public void testSimpleSendHeapByteBuf(TestInfo testInfo) throws java.lang.Throwable
java.lang.Throwable
public void testSimpleSendHeapByteBuf(Bootstrap sb, Bootstrap cb) throws java.lang.Throwable
java.lang.Throwable
public void testSimpleSendCompositeDirectByteBuf(TestInfo testInfo) throws java.lang.Throwable
java.lang.Throwable
public void testSimpleSendCompositeDirectByteBuf(Bootstrap sb, Bootstrap cb) throws java.lang.Throwable
java.lang.Throwable
public void testSimpleSendCompositeHeapByteBuf(TestInfo testInfo) throws java.lang.Throwable
java.lang.Throwable
public void testSimpleSendCompositeHeapByteBuf(Bootstrap sb, Bootstrap cb) throws java.lang.Throwable
java.lang.Throwable
public void testSimpleSendCompositeMixedByteBuf(TestInfo testInfo) throws java.lang.Throwable
java.lang.Throwable
public void testSimpleSendCompositeMixedByteBuf(Bootstrap sb, Bootstrap cb) throws java.lang.Throwable
java.lang.Throwable
public void testSimpleSendWithoutBind(TestInfo testInfo) throws java.lang.Throwable
java.lang.Throwable
public void testSimpleSendWithoutBind(Bootstrap sb, Bootstrap cb) throws java.lang.Throwable
java.lang.Throwable
public void testSimpleSendWithConnect(TestInfo testInfo) throws java.lang.Throwable
java.lang.Throwable
public void testSimpleSendWithConnect(Bootstrap sb, Bootstrap cb) throws java.lang.Throwable
java.lang.Throwable
public void testReceiveEmptyDatagrams(TestInfo testInfo) throws java.lang.Throwable
java.lang.Throwable
public void testReceiveEmptyDatagrams(Bootstrap sb, Bootstrap cb) throws java.lang.Throwable
java.lang.Throwable
public void testSendToUnresolvableAddress(TestInfo testInfo) throws java.lang.Throwable
java.lang.Throwable
public void testSendToUnresolvableAddress(Bootstrap sb, Bootstrap cb) throws java.lang.Throwable
java.lang.Throwable
protected abstract boolean isConnected(Channel channel)
protected abstract Channel setupClientChannel(Bootstrap cb, byte[] bytes, java.util.concurrent.CountDownLatch latch, java.util.concurrent.atomic.AtomicReference<java.lang.Throwable> errorRef) throws java.lang.Throwable
java.lang.Throwable
protected abstract Channel setupServerChannel(Bootstrap sb, byte[] bytes, java.net.SocketAddress sender, java.util.concurrent.CountDownLatch latch, java.util.concurrent.atomic.AtomicReference<java.lang.Throwable> errorRef, boolean echo) throws java.lang.Throwable
java.lang.Throwable
protected abstract boolean supportDisconnect()
protected boolean disconnectMightFail(DatagramChannel channel)
protected abstract ChannelFuture write(Channel cc, ByteBuf buf, java.net.SocketAddress remote, DatagramUnicastTest.WrapType wrapType)
protected static void closeChannel(Channel channel) throws java.lang.Exception
java.lang.Exception
protected java.net.InetSocketAddress sendToAddress(java.net.InetSocketAddress serverAddress)