提交 97977a49 编写于 作者: A alanb

8003285: TEST_BUG: java/nio/channels/AsynchronousChannelGroup/Unbounded.java fails again [macosx]

Reviewed-by: chegar
上级 330a9b3f
......@@ -39,6 +39,9 @@ public class Unbounded {
// set to true if an I/O operation fails
static volatile boolean failed;
// set to true when the test is done
static volatile boolean finished;
public static void main(String[] args) throws Exception {
// all accepted connections are added to a queue
final ArrayBlockingQueue<AsynchronousSocketChannel> queue =
......@@ -54,8 +57,10 @@ public class Unbounded {
listener.accept((Void)null, this);
}
public void failed(Throwable exc, Void att) {
failed = true;
System.err.println("accept failed: " + exc);
if (!finished) {
failed = true;
System.err.println("accept failed: " + exc);
}
}
});
System.out.println("Listener created.");
......@@ -120,8 +125,11 @@ public class Unbounded {
// wait for all threads to reach the barrier
System.out.println("Waiting for all threads to reach barrier");
barrier.await();
// finish up
finished = true;
listener.close();
if (failed)
throw new RuntimeException("I/O failed failed, see log for details");
throw new RuntimeException("I/O operation failed, see log for details");
}
}
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册