author | chegar |
Tue, 17 Apr 2018 08:54:17 -0700 | |
changeset 49765 | ee6f7a61f3a5 |
parent 48083 | b1c1b4ef4be2 |
child 56451 | 9585061fdb04 |
child 58968 | 7f1daafda27b |
permissions | -rw-r--r-- |
36433
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
1 |
/* |
49765 | 2 |
* Copyright (c) 2015, 2018, Oracle and/or its affiliates. All rights reserved. |
36433
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
3 |
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. |
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
4 |
* |
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
5 |
* This code is free software; you can redistribute it and/or modify it |
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
6 |
* under the terms of the GNU General Public License version 2 only, as |
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
7 |
* published by the Free Software Foundation. |
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
8 |
* |
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
9 |
* This code is distributed in the hope that it will be useful, but WITHOUT |
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
10 |
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or |
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
11 |
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License |
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
12 |
* version 2 for more details (a copy is included in the LICENSE file that |
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
13 |
* accompanied this code). |
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
14 |
* |
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
15 |
* You should have received a copy of the GNU General Public License version |
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
16 |
* 2 along with this work; if not, write to the Free Software Foundation, |
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
17 |
* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA. |
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
18 |
* |
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
19 |
* Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA |
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
20 |
* or visit www.oracle.com if you need additional information or have any |
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
21 |
* questions. |
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
22 |
*/ |
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
23 |
|
48083 | 24 |
import java.io.IOException; |
25 |
import java.io.InputStream; |
|
26 |
import java.io.OutputStream; |
|
27 |
import java.io.UncheckedIOException; |
|
49765 | 28 |
import java.net.InetAddress; |
29 |
import java.net.InetSocketAddress; |
|
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
30 |
import java.net.ServerSocket; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
31 |
import java.net.Socket; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
32 |
import java.net.URI; |
49765 | 33 |
import java.net.http.HttpClient; |
34 |
import java.net.http.HttpRequest; |
|
35 |
import java.net.http.HttpRequest.BodyPublishers; |
|
36 |
import java.net.http.HttpResponse; |
|
37 |
import java.net.http.HttpResponse.BodyHandlers; |
|
38 |
import java.net.http.HttpTimeoutException; |
|
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
39 |
import java.nio.file.Files; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
40 |
import java.nio.file.Path; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
41 |
import java.nio.file.Paths; |
36433
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
42 |
import java.nio.ByteBuffer; |
48083 | 43 |
import java.util.ArrayList; |
44 |
import java.util.List; |
|
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
45 |
import java.util.concurrent.CompletableFuture; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
46 |
import java.util.concurrent.ExecutionException; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
47 |
import java.util.concurrent.Flow; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
48 |
import java.util.concurrent.TimeoutException; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
49 |
import java.util.concurrent.TimeUnit; |
48083 | 50 |
import java.util.function.Supplier; |
51 |
import static java.lang.System.err; |
|
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
52 |
import static java.nio.charset.StandardCharsets.US_ASCII; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
53 |
import static java.nio.charset.StandardCharsets.UTF_8; |
36433
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
54 |
|
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
55 |
/** |
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
56 |
* @test |
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
57 |
* @bug 8151441 |
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
58 |
* @summary Request body of incorrect (larger or smaller) sizes than that |
48083 | 59 |
* reported by the body publisher |
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
60 |
* @run main/othervm ShortRequestBody |
36433
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
61 |
*/ |
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
62 |
|
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
63 |
public class ShortRequestBody { |
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
64 |
|
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
65 |
static final Path testSrc = Paths.get(System.getProperty("test.src", ".")); |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
66 |
|
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
67 |
// Some body types ( sources ) for testing. |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
68 |
static final String STRING_BODY = "Hello world"; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
69 |
static final byte[] BYTE_ARRAY_BODY = new byte[] { |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
70 |
(byte)0xCA, (byte)0xFE, (byte)0xBA, (byte)0xBE }; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
71 |
static final Path FILE_BODY = testSrc.resolve("docs").resolve("files").resolve("foo.txt"); |
36433
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
72 |
|
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
73 |
// Body lengths and offsets ( amount to be wrong by ), to make coordination |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
74 |
// between client and server easier. |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
75 |
static final int[] BODY_LENGTHS = new int[] { STRING_BODY.length(), |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
76 |
BYTE_ARRAY_BODY.length, |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
77 |
fileSize(FILE_BODY) }; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
78 |
static final int[] BODY_OFFSETS = new int[] { 0, +1, -1, +2, -2, +3, -3 }; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
79 |
|
48083 | 80 |
// A delegating Body Publisher. Subtypes will have a concrete body type. |
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
81 |
static abstract class AbstractDelegateRequestBody |
48083 | 82 |
implements HttpRequest.BodyPublisher { |
36433
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
83 |
|
48083 | 84 |
final HttpRequest.BodyPublisher delegate; |
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
85 |
final long contentLength; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
86 |
|
48083 | 87 |
AbstractDelegateRequestBody(HttpRequest.BodyPublisher delegate, |
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
88 |
long contentLength) { |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
89 |
this.delegate = delegate; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
90 |
this.contentLength = contentLength; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
91 |
} |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
92 |
|
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
93 |
@Override |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
94 |
public void subscribe(Flow.Subscriber<? super ByteBuffer> subscriber) { |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
95 |
delegate.subscribe(subscriber); |
36433
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
96 |
} |
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
97 |
|
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
98 |
@Override |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
99 |
public long contentLength() { return contentLength; /* may be wrong! */ } |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
100 |
} |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
101 |
|
48083 | 102 |
// Request body Publishers that may generate a different number of actual |
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
103 |
// bytes to that of what is reported through their {@code contentLength}. |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
104 |
|
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
105 |
static class StringRequestBody extends AbstractDelegateRequestBody { |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
106 |
StringRequestBody(String body, int additionalLength) { |
49765 | 107 |
super(HttpRequest.BodyPublishers.ofString(body), |
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
108 |
body.getBytes(UTF_8).length + additionalLength); |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
109 |
} |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
110 |
} |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
111 |
|
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
112 |
static class ByteArrayRequestBody extends AbstractDelegateRequestBody { |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
113 |
ByteArrayRequestBody(byte[] body, int additionalLength) { |
49765 | 114 |
super(BodyPublishers.ofByteArray(body), |
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
115 |
body.length + additionalLength); |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
116 |
} |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
117 |
} |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
118 |
|
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
119 |
static class FileRequestBody extends AbstractDelegateRequestBody { |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
120 |
FileRequestBody(Path path, int additionalLength) throws IOException { |
49765 | 121 |
super(BodyPublishers.ofFile(path), |
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
122 |
Files.size(path) + additionalLength); |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
123 |
} |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
124 |
} |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
125 |
|
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
126 |
// --- |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
127 |
|
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
128 |
public static void main(String[] args) throws Exception { |
48083 | 129 |
HttpClient sharedClient = HttpClient.newHttpClient(); |
130 |
List<Supplier<HttpClient>> clientSuppliers = new ArrayList<>(); |
|
131 |
clientSuppliers.add(() -> HttpClient.newHttpClient()); |
|
132 |
clientSuppliers.add(() -> sharedClient); |
|
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
133 |
|
48083 | 134 |
try (Server server = new Server()) { |
135 |
for (Supplier<HttpClient> cs : clientSuppliers) { |
|
136 |
err.println("\n---- next supplier ----\n"); |
|
49765 | 137 |
URI uri = new URI("http://localhost:" + server.getPort() + "/"); |
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
138 |
|
48083 | 139 |
// sanity ( 6 requests to keep client and server offsets easy to workout ) |
140 |
success(cs, uri, new StringRequestBody(STRING_BODY, 0)); |
|
141 |
success(cs, uri, new ByteArrayRequestBody(BYTE_ARRAY_BODY, 0)); |
|
142 |
success(cs, uri, new FileRequestBody(FILE_BODY, 0)); |
|
143 |
success(cs, uri, new StringRequestBody(STRING_BODY, 0)); |
|
144 |
success(cs, uri, new ByteArrayRequestBody(BYTE_ARRAY_BODY, 0)); |
|
145 |
success(cs, uri, new FileRequestBody(FILE_BODY, 0)); |
|
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
146 |
|
48083 | 147 |
for (int i = 1; i < BODY_OFFSETS.length; i++) { |
148 |
failureBlocking(cs, uri, new StringRequestBody(STRING_BODY, BODY_OFFSETS[i])); |
|
149 |
failureBlocking(cs, uri, new ByteArrayRequestBody(BYTE_ARRAY_BODY, BODY_OFFSETS[i])); |
|
150 |
failureBlocking(cs, uri, new FileRequestBody(FILE_BODY, BODY_OFFSETS[i])); |
|
151 |
||
152 |
failureNonBlocking(cs, uri, new StringRequestBody(STRING_BODY, BODY_OFFSETS[i])); |
|
153 |
failureNonBlocking(cs, uri, new ByteArrayRequestBody(BYTE_ARRAY_BODY, BODY_OFFSETS[i])); |
|
154 |
failureNonBlocking(cs, uri, new FileRequestBody(FILE_BODY, BODY_OFFSETS[i])); |
|
155 |
} |
|
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
156 |
} |
36433
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
157 |
} |
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
158 |
} |
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
159 |
|
48083 | 160 |
static void success(Supplier<HttpClient> clientSupplier, |
161 |
URI uri, |
|
162 |
HttpRequest.BodyPublisher publisher) |
|
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
163 |
throws Exception |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
164 |
{ |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
165 |
CompletableFuture<HttpResponse<Void>> cf; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
166 |
HttpRequest request = HttpRequest.newBuilder(uri) |
48083 | 167 |
.POST(publisher) |
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
168 |
.build(); |
49765 | 169 |
cf = clientSupplier.get().sendAsync(request, BodyHandlers.discarding()); |
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
170 |
|
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
171 |
HttpResponse<Void> resp = cf.get(30, TimeUnit.SECONDS); |
48083 | 172 |
err.println("Response code: " + resp.statusCode()); |
49765 | 173 |
check(resp.statusCode() == 200, null, |
174 |
"Expected 200, got ", resp.statusCode()); |
|
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
175 |
} |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
176 |
|
48083 | 177 |
static void failureNonBlocking(Supplier<HttpClient> clientSupplier, |
178 |
URI uri, |
|
179 |
HttpRequest.BodyPublisher publisher) |
|
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
180 |
throws Exception |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
181 |
{ |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
182 |
CompletableFuture<HttpResponse<Void>> cf; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
183 |
HttpRequest request = HttpRequest.newBuilder(uri) |
48083 | 184 |
.POST(publisher) |
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
185 |
.build(); |
49765 | 186 |
cf = clientSupplier.get().sendAsync(request, BodyHandlers.discarding()); |
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
187 |
|
36433
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
188 |
try { |
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
189 |
HttpResponse<Void> r = cf.get(30, TimeUnit.SECONDS); |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
190 |
throw new RuntimeException("Unexpected response: " + r.statusCode()); |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
191 |
} catch (TimeoutException x) { |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
192 |
throw new RuntimeException("Unexpected timeout", x); |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
193 |
} catch (ExecutionException expected) { |
48083 | 194 |
err.println("Caught expected: " + expected); |
195 |
Throwable t = expected.getCause(); |
|
49765 | 196 |
check(t instanceof IOException, t, |
197 |
"Expected cause IOException, but got: ", t); |
|
48083 | 198 |
String msg = t.getMessage(); |
199 |
check(msg.contains("Too many") || msg.contains("Too few"), |
|
49765 | 200 |
t, "Expected Too many|Too few, got: ", t); |
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
201 |
} |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
202 |
} |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
203 |
|
48083 | 204 |
static void failureBlocking(Supplier<HttpClient> clientSupplier, |
205 |
URI uri, |
|
206 |
HttpRequest.BodyPublisher publisher) |
|
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
207 |
throws Exception |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
208 |
{ |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
209 |
HttpRequest request = HttpRequest.newBuilder(uri) |
48083 | 210 |
.POST(publisher) |
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
211 |
.build(); |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
212 |
try { |
49765 | 213 |
HttpResponse<Void> r = clientSupplier.get() |
214 |
.send(request, BodyHandlers.discarding()); |
|
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
215 |
throw new RuntimeException("Unexpected response: " + r.statusCode()); |
48083 | 216 |
} catch (HttpTimeoutException x) { |
217 |
throw new RuntimeException("Unexpected timeout", x); |
|
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
218 |
} catch (IOException expected) { |
48083 | 219 |
err.println("Caught expected: " + expected); |
220 |
String msg = expected.getMessage(); |
|
221 |
check(msg.contains("Too many") || msg.contains("Too few"), |
|
49765 | 222 |
expected,"Expected Too many|Too few, got: ", expected); |
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
223 |
} |
36433
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
224 |
} |
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
225 |
|
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
226 |
static class Server extends Thread implements AutoCloseable { |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
227 |
|
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
228 |
static String RESPONSE = "HTTP/1.1 200 OK\r\n" + |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
229 |
"Connection: close\r\n"+ |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
230 |
"Content-length: 0\r\n\r\n"; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
231 |
|
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
232 |
private final ServerSocket ss; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
233 |
private volatile boolean closed; |
36433
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
234 |
|
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
235 |
Server() throws IOException { |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
236 |
super("Test-Server"); |
49765 | 237 |
ss = new ServerSocket(); |
238 |
ss.setReuseAddress(false); |
|
239 |
ss.bind(new InetSocketAddress(InetAddress.getLoopbackAddress(), 0)); |
|
240 |
this.start(); |
|
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
241 |
} |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
242 |
|
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
243 |
int getPort() { return ss.getLocalPort(); } |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
244 |
|
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
245 |
@Override |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
246 |
public void run() { |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
247 |
int count = 0; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
248 |
int offset = 0; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
249 |
|
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
250 |
while (!closed) { |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
251 |
try (Socket s = ss.accept()) { |
48083 | 252 |
err.println("Server: got connection"); |
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
253 |
InputStream is = s.getInputStream(); |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
254 |
readRequestHeaders(is); |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
255 |
byte[] ba = new byte[1024]; |
36433
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
256 |
|
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
257 |
int length = BODY_LENGTHS[count % 3]; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
258 |
length += BODY_OFFSETS[offset]; |
48083 | 259 |
err.println("Server: count=" + count + ", offset=" + offset); |
260 |
err.println("Server: expecting " +length+ " bytes"); |
|
261 |
int read = is.readNBytes(ba, 0, length); |
|
262 |
err.println("Server: actually read " + read + " bytes"); |
|
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
263 |
|
48083 | 264 |
// Update the counts before replying, to prevent the |
265 |
// client-side racing reset with this thread. |
|
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
266 |
count++; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
267 |
if (count % 6 == 0) // 6 is the number of failure requests per offset |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
268 |
offset++; |
48083 | 269 |
if (count % 42 == 0) { |
270 |
count = 0; // reset, for second iteration |
|
271 |
offset = 0; |
|
272 |
} |
|
273 |
||
274 |
if (read < length) { |
|
275 |
// no need to reply, client has already closed |
|
276 |
// ensure closed |
|
277 |
if (is.read() != -1) |
|
278 |
new AssertionError("Unexpected read"); |
|
279 |
} else { |
|
280 |
OutputStream os = s.getOutputStream(); |
|
281 |
err.println("Server: writing " |
|
282 |
+ RESPONSE.getBytes(US_ASCII).length + " bytes"); |
|
283 |
os.write(RESPONSE.getBytes(US_ASCII)); |
|
284 |
} |
|
285 |
||
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
286 |
} catch (IOException e) { |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
287 |
if (!closed) |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
288 |
System.out.println("Unexpected" + e); |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
289 |
} |
36433
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
290 |
} |
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
291 |
} |
36433
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
292 |
|
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
293 |
@Override |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
294 |
public void close() { |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
295 |
if (closed) |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
296 |
return; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
297 |
closed = true; |
36433
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
298 |
try { |
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
299 |
ss.close(); |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
300 |
} catch (IOException e) { |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
301 |
throw new UncheckedIOException("Unexpected", e); |
36433
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
302 |
} |
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
303 |
} |
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
304 |
} |
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
305 |
|
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
306 |
static final byte[] requestEnd = new byte[] {'\r', '\n', '\r', '\n' }; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
307 |
|
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
308 |
// Read until the end of a HTTP request headers |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
309 |
static void readRequestHeaders(InputStream is) throws IOException { |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
310 |
int requestEndCount = 0, r; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
311 |
while ((r = is.read()) != -1) { |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
312 |
if (r == requestEnd[requestEndCount]) { |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
313 |
requestEndCount++; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
314 |
if (requestEndCount == 4) { |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
315 |
break; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
316 |
} |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
317 |
} else { |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
318 |
requestEndCount = 0; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
319 |
} |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
320 |
} |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
321 |
} |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
322 |
|
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
323 |
static int fileSize(Path p) { |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
324 |
try { return (int) Files.size(p); } |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
325 |
catch (IOException x) { throw new UncheckedIOException(x); } |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
326 |
} |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
327 |
|
49765 | 328 |
static boolean check(boolean cond, Throwable t, Object... failedArgs) { |
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
329 |
if (cond) |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
330 |
return true; |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
331 |
// We are going to fail... |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
332 |
StringBuilder sb = new StringBuilder(); |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
333 |
for (Object o : failedArgs) |
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
334 |
sb.append(o); |
49765 | 335 |
throw new RuntimeException(sb.toString(), t); |
42460
7133f144981a
8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
36433
diff
changeset
|
336 |
} |
36433
dcbc230cfa4f
8151441: Completion result in httpclient Exchange.java lost
michaelm
parents:
diff
changeset
|
337 |
} |