--- /dev/null 2017-10-28 22:49:55.551349757 -0700 +++ new/test/jdk/java/net/httpclient/ZeroRedirects.java 2017-11-30 04:06:02.846879350 -0800 @@ -0,0 +1,117 @@ +/* + * Copyright (c) 2017, 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 + * under the terms of the GNU General Public License version 2 only, as + * published by the Free Software Foundation. + * + * This code is distributed in the hope that it will be useful, but WITHOUT + * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or + * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License + * version 2 for more details (a copy is included in the LICENSE file that + * accompanied this code). + * + * You should have received a copy of the GNU General Public License version + * 2 along with this work; if not, write to the Free Software Foundation, + * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA. + * + * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA + * or visit www.oracle.com if you need additional information or have any + * questions. + */ + +/* + * @test + * @bug 8164941 + * @modules jdk.incubator.httpclient java.logging jdk.httpserver + * @run main/othervm ZeroRedirects + */ + +import com.sun.net.httpserver.Headers; +import com.sun.net.httpserver.HttpContext; +import com.sun.net.httpserver.HttpExchange; +import com.sun.net.httpserver.HttpHandler; +import com.sun.net.httpserver.HttpServer; +import java.io.IOException; +import java.io.OutputStream; +import java.net.URI; +import java.util.concurrent.Executors; +import java.util.concurrent.ExecutorService; +import java.net.InetSocketAddress; +import jdk.incubator.http.HttpClient; +import jdk.incubator.http.HttpRequest; +import jdk.incubator.http.HttpResponse; +import static jdk.incubator.http.HttpRequest.BodyPublisher.fromString; +import static jdk.incubator.http.HttpResponse.BodyHandler.asString; +import static jdk.incubator.http.HttpResponse.BodyHandler.discard; +import static jdk.incubator.http.HttpClient.Version.HTTP_1_1; +import static jdk.incubator.http.HttpClient.Version.HTTP_2; + +/** + */ +public class ZeroRedirects { + static HttpServer s1 ; + static ExecutorService executor; + static int port; + static HttpClient client; + static URI uri; + + public static void main(String[] args) throws Exception { + initServer(); + + client = HttpClient.newBuilder() + .executor(executor) + .followRedirects(HttpClient.Redirect.ALWAYS) + .build(); + try { + test(); + } finally { + s1.stop(0); + executor.shutdownNow(); + } + } + + public static void test() throws Exception { + System.setProperty("java.net.httpclient.redirects.retrylimit", "0"); + HttpRequest r = HttpRequest.newBuilder(uri) + .GET() + .build(); + HttpResponse resp = client.send(r, discard(null)); + System.out.printf("Client: response is %d\n", resp.statusCode()); + if (resp.statusCode() != 200) + throw new RuntimeException(); + } + + static void initServer() throws Exception { + InetSocketAddress addr = new InetSocketAddress (0); + s1 = HttpServer.create (addr, 0); + HttpHandler h = new Handler(); + + HttpContext c1 = s1.createContext("/", h); + + executor = Executors.newCachedThreadPool(); + s1.setExecutor(executor); + s1.start(); + + port = s1.getAddress().getPort(); + uri = new URI("http://127.0.0.1:" + Integer.toString(port) + "/foo"); + System.out.println("HTTP server port = " + port); + } +} + +class Handler implements HttpHandler { + + @Override + public synchronized void handle(HttpExchange t) + throws IOException + { + String reply = "Hello world"; + int len = reply.length(); + System.out.printf("Sending response 200\n"); + t.sendResponseHeaders(200, len); + OutputStream o = t.getResponseBody(); + o.write(reply.getBytes()); + t.close(); + } +}