test/jdk/java/net/Socket/asyncClose/Race.java
author michaelm
Wed, 11 Apr 2018 10:19:37 +0100
changeset 49573 6b46983d6fbe
parent 47216 71c04702a3d5
child 55045 3a8433d967ea
permissions -rw-r--r--
8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused Reviewed-by: dfuchs
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
15522
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
     1
/*
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
     2
 * Copyright (c) 2013, Oracle and/or its affiliates. All rights reserved.
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
     3
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
     4
 *
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
     5
 * This code is free software; you can redistribute it and/or modify it
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
     6
 * under the terms of the GNU General Public License version 2 only, as
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
     7
 * published by the Free Software Foundation.
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
     8
 *
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
     9
 * This code is distributed in the hope that it will be useful, but WITHOUT
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    10
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    11
 * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    12
 * version 2 for more details (a copy is included in the LICENSE file that
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    13
 * accompanied this code).
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    14
 *
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    15
 * You should have received a copy of the GNU General Public License version
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    16
 * 2 along with this work; if not, write to the Free Software Foundation,
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    17
 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    18
 *
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    19
 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    20
 * or visit www.oracle.com if you need additional information or have any
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    21
 * questions.
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    22
 */
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    23
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    24
/*
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    25
 * @test
16866
e659009ee08d 8012244: java/net/Socket/asyncClose/Race.java fails intermittently on Windows
chegar
parents: 15522
diff changeset
    26
 * @bug 8006395 8012244
e659009ee08d 8012244: java/net/Socket/asyncClose/Race.java fails intermittently on Windows
chegar
parents: 15522
diff changeset
    27
 * @summary Tests racing code that reads and closes a Socket
15522
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    28
 */
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    29
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    30
import java.io.InputStream;
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    31
import java.net.ServerSocket;
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    32
import java.net.Socket;
49573
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    33
import java.net.ConnectException;
15522
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    34
import java.net.SocketException;
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    35
import java.util.concurrent.Phaser;
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    36
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    37
// Racey test, will not always fail, but if it does then we have a problem.
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    38
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    39
public class Race {
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    40
    final static int THREADS = 100;
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    41
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    42
    public static void main(String[] args) throws Exception {
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    43
        try (ServerSocket ss = new ServerSocket(0)) {
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    44
            final int port = ss.getLocalPort();
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    45
            final Phaser phaser = new Phaser(THREADS + 1);
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    46
            for (int i=0; i<100; i++) {
49573
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    47
                try {
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    48
                    final Socket s = new Socket("localhost", port);
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    49
                    s.setSoLinger(false, 0);
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    50
                    try (Socket sa = ss.accept()) {
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    51
                        sa.setSoLinger(false, 0);
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    52
                        final InputStream is = s.getInputStream();
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    53
                        Thread[] threads = new Thread[THREADS];
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    54
                        for (int j=0; j<THREADS; j++) {
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    55
                            threads[j] = new Thread() {
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    56
                            public void run() {
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    57
                                try {
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    58
                                    phaser.arriveAndAwaitAdvance();
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    59
                                    while (is.read() != -1)
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    60
                                        Thread.sleep(50);
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    61
                                } catch (Exception x) {
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    62
                                    if (!(x instanceof SocketException
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    63
                                          && x.getMessage().equalsIgnoreCase("socket closed")))
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    64
                                        x.printStackTrace();
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    65
                                    // ok, expect Socket closed
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    66
                                }
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    67
                            }};
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    68
                        }
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    69
                        for (int j=0; j<100; j++)
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    70
                            threads[j].start();
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    71
                        phaser.arriveAndAwaitAdvance();
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    72
                        s.close();
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    73
                        for (int j=0; j<100; j++)
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    74
                            threads[j].join();
15522
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    75
                    }
49573
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    76
                } catch (ConnectException e) {
6b46983d6fbe 8196775: java/net/Socket/asyncClose/Race.java failed intermittently on Windows with ConnectException: Connection refused
michaelm
parents: 47216
diff changeset
    77
                    System.err.println("Exception " + e + " Port: " + port);
15522
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    78
                }
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    79
            }
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    80
        }
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    81
    }
e6d9ef53b499 8006395: Race in async socket close on Linux
chegar
parents:
diff changeset
    82
}