infernap12/jdk
1
0
Fork 0
mirror of https://github.com/openjdk/jdk.git synced 2026-02-22 08:21:27 +00:00
Code Issues Packages Projects Releases Wiki Activity

8286610: Add additional diagnostic output to java/net/DatagramSocket/InterruptibleDatagramSocket.java

Browse Source 
Reviewed-by: msheppar, dfuchs, jpai
This commit is contained in:
Bill Huang 2022-07-03 02:37:30 +00:00 committed by Jaikiran Pai
parent 70f5693356
commit d8444aa45e
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
test/jdk/java/net/DatagramSocket/InterruptibleDatagramSocket.java
View File

@ -1,5 +1,5 @@
/*
* Copyright (c) 2019, 2021, Oracle and/or its affiliates. All rights reserved.
* Copyright (c) 2019, 2022, 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
@ -28,6 +28,7 @@ import java.net.SocketException;
import java.net.SocketTimeoutException;
import java.nio.channels.ClosedByInterruptException;
import java.nio.channels.DatagramChannel;
import java.util.Arrays;
import java.util.concurrent.CountDownLatch;
import static java.lang.Thread.sleep;
@ -60,6 +61,8 @@ public class InterruptibleDatagramSocket {
latch.countDown();
try {
s.receive(p);
System.out.println("Received data " + Arrays.toString(p.getData())
+ " from " + p.getSocketAddress());
} finally {
try {
coordinator.join();
@ -95,12 +98,18 @@ public class InterruptibleDatagramSocket {
public static void main(String[] args) throws Exception {
try (DatagramSocket s = new DatagramSocket()) {
System.out.println("Testing interrupt of DatagramSocket receive " +
"on endpoint " + s.getLocalSocketAddress());
test(s, false);
}
try (DatagramSocket s = new MulticastSocket()) {
System.out.println("Testing interrupt of MulticastSocket receive" +
" on endpoint " + s.getLocalSocketAddress());
test(s, false);
}
try (DatagramSocket s = DatagramChannel.open().socket()) {
try (DatagramSocket s = DatagramChannel.open().bind(null).socket()) {
System.out.println("Testing interrupt of DatagramChannel socket " +
"receive on endpoint " + s.getLocalSocketAddress());
test(s, true);
}
}