test/java/nio/channels/AsynchronousChannelGroup/Basic.java

@@ -87,14 +87,13 @@
                 int nThreads = 1 + rand.nextInt(8);
                 group = AsynchronousChannelGroup.withFixedThreadPool(nThreads, threadFactory);
             }
             // create channel that is bound to group
             AsynchronousChannel ch;
-            switch (rand.nextInt(3)) {
+            switch (rand.nextInt(2)) {
                 case 0 : ch = AsynchronousSocketChannel.open(group); break;
                 case 1 : ch = AsynchronousServerSocketChannel.open(group); break;
-                case 2 : ch = AsynchronousDatagramChannel.open(null, group); break;
                 default : throw new AssertionError();
             }
             group.shutdown();
             if (!group.isShutdown())
                 throw new RuntimeException("Group should be shutdown");

@@ -126,22 +125,13 @@
                 group = AsynchronousChannelGroup
                     .withFixedThreadPool(nThreads, threadFactory);
             }
 
             // I/O in progress
-            AsynchronousChannel ch;
-            if (rand.nextBoolean()) {
-                AsynchronousServerSocketChannel listener = AsynchronousServerSocketChannel
+            AsynchronousServerSocketChannel ch = AsynchronousServerSocketChannel
                     .open(group).bind(new InetSocketAddress(0));
-                listener.accept();
-                ch = listener;
-            } else {
-                AsynchronousDatagramChannel adc =
-                    AsynchronousDatagramChannel.open(null, group);
-                adc.receive(ByteBuffer.allocate(100));
-                ch = adc;
-            }
+            ch.accept();
 
             // forceful shutdown
             group.shutdownNow();
 
             // shutdownNow is required to close all channels