jdk-sandbox: comparison test/jdk/java/nio/channels/AsynchronousSocketChannel/Basic.java

equal deleted inserted replaced

-:dd5db907ab7e
+:799e6e42b95f
 /*
-* Copyright (c) 2008, 2017, Oracle and/or its affiliates. All rights reserved.
+* Copyright (c) 2008, 2018, Oracle and/or its affiliates. All rights reserved.
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
 *
 * This code is free software; you can redistribute it and/or modify it
 * under the terms of the GNU General Public License version 2 only, as
 * published by the Free Software Foundation.
 /* @test
 * @bug 4607272 6842687 6878369 6944810 7023403
 * @summary Unit test for AsynchronousSocketChannel(use -Dseed=X to set PRNG seed)
 * @library /test/lib
-* @build jdk.test.lib.RandomFactory
+* @build jdk.test.lib.RandomFactory jdk.test.lib.Utils
-* @run main Basic -skipSlowConnectTest
+* @run main/othervm/timeout=600 Basic -skipSlowConnectTest
 * @key randomness intermittent
 */
 import java.io.Closeable;
 import java.io.IOException;
 static class Server implements Closeable {
 private final ServerSocketChannel ssc;
 private final InetSocketAddress address;
 Server() throws IOException {
-ssc = ServerSocketChannel.open().bind(new InetSocketAddress(0));
+this(0);
+}
-InetAddress lh = InetAddress.getLocalHost();
-int port = ((InetSocketAddress)(ssc.getLocalAddress())).getPort();
+Server(int recvBufSize) throws IOException {
-address = new InetSocketAddress(lh, port);
+ssc = ServerSocketChannel.open();
+if (recvBufSize > 0) {
+ssc.setOption(SO_RCVBUF, recvBufSize);
+}
+ssc.bind(new InetSocketAddress(InetAddress.getLoopbackAddress(), 0));
+address = (InetSocketAddress)ssc.getLocalAddress();
 }
 InetSocketAddress address() {
 return address;
 }
 // expected
 }
 System.out.println("-- asynchronous close when reading --");
-try (Server server = new Server()) {
+try (Server server = new Server(1)) {
 ch = AsynchronousSocketChannel.open();
 ch.connect(server.address()).get();
 ByteBuffer dst = ByteBuffer.allocateDirect(100);
 Future<Integer> result = ch.read(dst);
 System.out.println("-- asynchronous close when writing --");
 ch = AsynchronousSocketChannel.open();
 ch.connect(server.address()).get();
+SocketChannel peer = server.accept();
+peer.setOption(SO_RCVBUF, 1);
 final AtomicReference<Throwable> writeException =
 new AtomicReference<Throwable>();
 // write bytes to fill socket buffer
 final AtomicInteger numCompleted = new AtomicInteger();
 ch.write(genBuffer(), ch, new CompletionHandler<Integer,AsynchronousSocketChannel>() {
 public void completed(Integer result, AsynchronousSocketChannel ch) {
+System.out.println("completed write to async channel: " + result);
 numCompleted.incrementAndGet();
 ch.write(genBuffer(), ch, this);
+System.out.println("started another write to async channel: " + result);
 }
 public void failed(Throwable x, AsynchronousSocketChannel ch) {
+System.out.println("failed write to async channel");
 writeException.set(x);
 }
 });
 // give time for socket buffer to fill up -
 // take pauses until the handler is no longer being invoked
 // because all writes are being pended which guarantees that
 // the internal channel state indicates it is writing
 int prevNumCompleted = numCompleted.get();
 do {
-Thread.sleep(1000);
+Thread.sleep((long)(1000 * jdk.test.lib.Utils.TIMEOUT_FACTOR));
+System.out.println("check if buffer is filled up");
 if (numCompleted.get() == prevNumCompleted) {
 break;
 }
 prevNumCompleted = numCompleted.get();
 } while (true);
 // attempt a concurrent write -
 // should fail with WritePendingException
 try {
+System.out.println("concurrent write to async channel");
 ch.write(genBuffer());
+System.out.format("prevNumCompleted: %d, numCompleted: %d%n",
+prevNumCompleted, numCompleted.get());
 throw new RuntimeException("WritePendingException expected");
 } catch (WritePendingException x) {
 }
 // close channel - should cause initial write to complete
+System.out.println("closing async channel...");
 ch.close();
-server.accept().close();
+System.out.println("closed async channel");
+peer.close();
 // wait for exception
 while (writeException.get() == null) {
 Thread.sleep(100);
 }

changeset 49840	799e6e42b95f
parent 47216	71c04702a3d5
child 50303	7164c3bb55df