author | chegar |
Sat, 03 Mar 2018 09:54:31 +0000 | |
branch | http-client-branch |
changeset 56233 | 1753108d07b9 |
parent 56167 | 96fa4f49a9ff |
child 56265 | ec34ae013fbe |
permissions | -rw-r--r-- |
44639
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
1 |
/* |
56167
96fa4f49a9ff
http-client-branch: CSR review commet - outboard pre-defined BP/BH/BS
chegar
parents:
56092
diff
changeset
|
2 |
* Copyright (c) 2015, 2018, Oracle and/or its affiliates. All rights reserved. |
44639
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
3 |
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
4 |
* |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
5 |
* This code is free software; you can redistribute it and/or modify it |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
6 |
* under the terms of the GNU General Public License version 2 only, as |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
7 |
* published by the Free Software Foundation. |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
8 |
* |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
9 |
* This code is distributed in the hope that it will be useful, but WITHOUT |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
10 |
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
11 |
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
12 |
* version 2 for more details (a copy is included in the LICENSE file that |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
13 |
* accompanied this code). |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
14 |
* |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
15 |
* You should have received a copy of the GNU General Public License version |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
16 |
* 2 along with this work; if not, write to the Free Software Foundation, |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
17 |
* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA. |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
18 |
* |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
19 |
* Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
20 |
* or visit www.oracle.com if you need additional information or have any |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
21 |
* questions. |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
22 |
*/ |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
23 |
|
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
24 |
import java.io.IOException; |
56233
1753108d07b9
http-client-branch: setReuseAddress(false) for all test ServerSockets
chegar
parents:
56167
diff
changeset
|
25 |
import java.net.InetSocketAddress; |
44639
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
26 |
import java.net.ServerSocket; |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
27 |
import java.net.URI; |
56089
42208b2f224e
http-client-branch: move to standard package and module name
chegar
parents:
56082
diff
changeset
|
28 |
import java.net.http.HttpClient; |
42208b2f224e
http-client-branch: move to standard package and module name
chegar
parents:
56082
diff
changeset
|
29 |
import java.net.http.HttpRequest; |
42208b2f224e
http-client-branch: move to standard package and module name
chegar
parents:
56082
diff
changeset
|
30 |
import java.net.http.HttpResponse; |
56167
96fa4f49a9ff
http-client-branch: CSR review commet - outboard pre-defined BP/BH/BS
chegar
parents:
56092
diff
changeset
|
31 |
import java.net.http.HttpResponse.BodyHandlers; |
56089
42208b2f224e
http-client-branch: move to standard package and module name
chegar
parents:
56082
diff
changeset
|
32 |
import java.net.http.HttpTimeoutException; |
44639
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
33 |
import java.time.Duration; |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
34 |
import java.util.concurrent.CompletableFuture; |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
35 |
import java.util.concurrent.ExecutorService; |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
36 |
import java.util.concurrent.Executors; |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
37 |
import java.util.concurrent.LinkedBlockingQueue; |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
38 |
import static java.lang.System.out; |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
39 |
|
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
40 |
/** |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
41 |
* @test |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
42 |
* @bug 8178147 |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
43 |
* @summary Ensures that small timeouts do not cause hangs due to race conditions |
56092
fd85b2bf2b0d
http-client-branch: move implementation to jdk.internal.net.http
chegar
parents:
56089
diff
changeset
|
44 |
* @run main/othervm -Djdk.internal.net.http.common.DEBUG=true SmallTimeout |
44639
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
45 |
*/ |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
46 |
|
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
47 |
// To enable logging use. Not enabled by default as it changes the dynamics |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
48 |
// of the test. |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
49 |
// @run main/othervm -Djdk.httpclient.HttpClient.log=all,frames:all SmallTimeout |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
50 |
|
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
51 |
public class SmallTimeout { |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
52 |
|
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
53 |
static int[] TIMEOUTS = {2, 1, 3, 2, 100, 1}; |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
54 |
|
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
55 |
// A queue for placing timed out requests so that their order can be checked. |
48083 | 56 |
static LinkedBlockingQueue<HttpResult> queue = new LinkedBlockingQueue<>(); |
57 |
||
58 |
static final class HttpResult { |
|
59 |
final HttpRequest request; |
|
60 |
final Throwable failed; |
|
61 |
HttpResult(HttpRequest request, Throwable failed) { |
|
62 |
this.request = request; |
|
63 |
this.failed = failed; |
|
64 |
} |
|
65 |
||
66 |
static HttpResult of(HttpRequest request) { |
|
67 |
return new HttpResult(request, null); |
|
68 |
} |
|
69 |
||
70 |
static HttpResult of(HttpRequest request, Throwable t) { |
|
71 |
return new HttpResult(request, t); |
|
72 |
} |
|
73 |
||
74 |
} |
|
44639
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
75 |
|
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
76 |
static volatile boolean error; |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
77 |
|
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
78 |
public static void main(String[] args) throws Exception { |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
79 |
HttpClient client = HttpClient.newHttpClient(); |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
80 |
|
56233
1753108d07b9
http-client-branch: setReuseAddress(false) for all test ServerSockets
chegar
parents:
56167
diff
changeset
|
81 |
try (ServerSocket ss = new ServerSocket()) { |
1753108d07b9
http-client-branch: setReuseAddress(false) for all test ServerSockets
chegar
parents:
56167
diff
changeset
|
82 |
ss.setReuseAddress(false); |
1753108d07b9
http-client-branch: setReuseAddress(false) for all test ServerSockets
chegar
parents:
56167
diff
changeset
|
83 |
ss.bind(new InetSocketAddress(0)); |
44639
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
84 |
int port = ss.getLocalPort(); |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
85 |
URI uri = new URI("http://127.0.0.1:" + port + "/"); |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
86 |
|
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
87 |
HttpRequest[] requests = new HttpRequest[TIMEOUTS.length]; |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
88 |
|
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
89 |
out.println("--- TESTING Async"); |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
90 |
for (int i = 0; i < TIMEOUTS.length; i++) { |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
91 |
requests[i] = HttpRequest.newBuilder(uri) |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
92 |
.timeout(Duration.ofMillis(TIMEOUTS[i])) |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
93 |
.GET() |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
94 |
.build(); |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
95 |
|
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
96 |
final HttpRequest req = requests[i]; |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
97 |
CompletableFuture<HttpResponse<Object>> response = client |
56167
96fa4f49a9ff
http-client-branch: CSR review commet - outboard pre-defined BP/BH/BS
chegar
parents:
56092
diff
changeset
|
98 |
.sendAsync(req, BodyHandlers.replacing(null)) |
44639
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
99 |
.whenComplete((HttpResponse<Object> r, Throwable t) -> { |
48083 | 100 |
Throwable cause = null; |
44639
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
101 |
if (r != null) { |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
102 |
out.println("Unexpected response: " + r); |
48083 | 103 |
cause = new RuntimeException("Unexpected response"); |
44639
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
104 |
error = true; |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
105 |
} |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
106 |
if (t != null) { |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
107 |
if (!(t.getCause() instanceof HttpTimeoutException)) { |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
108 |
out.println("Wrong exception type:" + t.toString()); |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
109 |
Throwable c = t.getCause() == null ? t : t.getCause(); |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
110 |
c.printStackTrace(); |
48083 | 111 |
cause = c; |
44639
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
112 |
error = true; |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
113 |
} else { |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
114 |
out.println("Caught expected timeout: " + t.getCause()); |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
115 |
} |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
116 |
} |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
117 |
if (t == null && r == null) { |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
118 |
out.println("Both response and throwable are null!"); |
48083 | 119 |
cause = new RuntimeException("Both response and throwable are null!"); |
44639
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
120 |
error = true; |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
121 |
} |
48083 | 122 |
queue.add(HttpResult.of(req,cause)); |
44639
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
123 |
}); |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
124 |
} |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
125 |
System.out.println("All requests submitted. Waiting ..."); |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
126 |
|
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
127 |
checkReturn(requests); |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
128 |
|
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
129 |
if (error) |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
130 |
throw new RuntimeException("Failed. Check output"); |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
131 |
|
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
132 |
// Repeat blocking in separate threads. Use queue to wait. |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
133 |
out.println("--- TESTING Sync"); |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
134 |
|
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
135 |
// For running blocking response tasks |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
136 |
ExecutorService executor = Executors.newCachedThreadPool(); |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
137 |
|
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
138 |
for (int i = 0; i < TIMEOUTS.length; i++) { |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
139 |
requests[i] = HttpRequest.newBuilder(uri) |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
140 |
.timeout(Duration.ofMillis(TIMEOUTS[i])) |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
141 |
.GET() |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
142 |
.build(); |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
143 |
|
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
144 |
final HttpRequest req = requests[i]; |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
145 |
executor.execute(() -> { |
48083 | 146 |
Throwable cause = null; |
44639
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
147 |
try { |
56167
96fa4f49a9ff
http-client-branch: CSR review commet - outboard pre-defined BP/BH/BS
chegar
parents:
56092
diff
changeset
|
148 |
client.send(req, BodyHandlers.replacing(null)); |
44639
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
149 |
} catch (HttpTimeoutException e) { |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
150 |
out.println("Caught expected timeout: " + e); |
48083 | 151 |
} catch (Throwable ee) { |
44639
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
152 |
Throwable c = ee.getCause() == null ? ee : ee.getCause(); |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
153 |
c.printStackTrace(); |
48083 | 154 |
cause = c; |
44639
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
155 |
error = true; |
48083 | 156 |
} finally { |
157 |
queue.offer(HttpResult.of(req, cause)); |
|
44639
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
158 |
} |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
159 |
}); |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
160 |
} |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
161 |
System.out.println("All requests submitted. Waiting ..."); |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
162 |
|
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
163 |
checkReturn(requests); |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
164 |
|
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
165 |
executor.shutdownNow(); |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
166 |
|
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
167 |
if (error) |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
168 |
throw new RuntimeException("Failed. Check output"); |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
169 |
|
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
170 |
} |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
171 |
} |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
172 |
|
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
173 |
static void checkReturn(HttpRequest[] requests) throws InterruptedException { |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
174 |
// wait for exceptions and check order |
48083 | 175 |
boolean ok = true; |
44639
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
176 |
for (int j = 0; j < TIMEOUTS.length; j++) { |
48083 | 177 |
HttpResult res = queue.take(); |
178 |
HttpRequest req = res.request; |
|
179 |
out.println("Got request from queue " + req + ", order: " + getRequest(req, requests) |
|
180 |
+ (res.failed == null ? "" : " failed: " + res.failed)); |
|
181 |
ok = ok && res.failed == null; |
|
44639
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
182 |
} |
48083 | 183 |
out.println("Return " + (ok ? "ok" : "nok")); |
44639
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
184 |
} |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
185 |
|
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
186 |
/** Returns the index of the request in the array. */ |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
187 |
static String getRequest(HttpRequest req, HttpRequest[] requests) { |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
188 |
for (int i=0; i<requests.length; i++) { |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
189 |
if (req == requests[i]) { |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
190 |
return "r" + i; |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
191 |
} |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
192 |
} |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
193 |
throw new AssertionError("Unknown request: " + req); |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
194 |
} |
5c2838d882a5
8178147: Race conditions in timeout handling code in http/2 incubator client
dfuchs
parents:
diff
changeset
|
195 |
} |