--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/jdk/test/java/net/httpclient/APIErrors.java Thu Feb 25 23:14:22 2016 +0000
@@ -0,0 +1,207 @@
+/*
+ * Copyright (c) 2015, 2016, 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 8087112
+ * @library /lib/testlibrary/
+ * @build jdk.testlibrary.SimpleSSLContext ProxyServer
+ * @compile ../../../com/sun/net/httpserver/LogFilter.java
+ * @compile ../../../com/sun/net/httpserver/FileServerHandler.java
+ * @run main/othervm APIErrors
+ */
+//package javaapplication16;
+
+import com.sun.net.httpserver.*;
+import java.io.IOException;
+import java.net.*;
+import java.net.http.*;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.concurrent.*;
+import java.util.function.Supplier;
+
+/**
+ * Does stupid things with API, to check appropriate errors/exceptions thrown
+ */
+public class APIErrors {
+
+ static HttpServer s1 = null;
+ static ExecutorService executor = null;
+ static int port;
+ static HttpClient client;
+ static String httproot, fileuri, fileroot;
+ static List<HttpClient> clients = new LinkedList<>();
+
+ public static void main(String[] args) throws Exception {
+ initServer();
+ fileroot = System.getProperty("test.src") + "/docs";
+
+ client = HttpClient.create().build();
+
+ clients.add(HttpClient.getDefault());
+
+ try {
+ test1();
+ test2();
+ test3();
+ } finally {
+ s1.stop(0);
+ executor.shutdownNow();
+ for (HttpClient client : clients)
+ client.executorService().shutdownNow();
+ }
+ }
+
+ static void reject(Runnable r, Class<? extends Exception> extype) {
+ try {
+ r.run();
+ throw new RuntimeException("Expected: " + extype);
+ } catch (Throwable t) {
+ if (!extype.isAssignableFrom(t.getClass())) {
+ throw new RuntimeException("Wrong exception type: " + extype + " / "
+ +t.getClass());
+ }
+ }
+ }
+
+ static void accept(Runnable r) {
+ try {
+ r.run();
+ } catch (Throwable t) {
+ throw new RuntimeException("Unexpected exception: " + t);
+ }
+ }
+
+ static void checkNonNull(Supplier<?> r) {
+ if (r.get() == null)
+ throw new RuntimeException("Unexpected null return:");
+ }
+
+ static void assertTrue(Supplier<Boolean> r) {
+ if (r.get() == false)
+ throw new RuntimeException("Assertion failure:");
+ }
+
+ // HttpClient.Builder
+ static void test1() throws Exception {
+ System.out.println("Test 1");
+ HttpClient.Builder cb = HttpClient.create();
+ InetSocketAddress addr = new InetSocketAddress("127.0.0.1", 5000);
+ reject(() -> { cb.priority(-1);}, IllegalArgumentException.class);
+ reject(() -> { cb.priority(500);}, IllegalArgumentException.class);
+ accept(() -> { cb.priority(1);});
+ accept(() -> { cb.priority(255);});
+
+ accept(() -> {clients.add(cb.build()); clients.add(cb.build());});
+ }
+
+ static void test2() throws Exception {
+ System.out.println("Test 2");
+ HttpClient.Builder cb = HttpClient.create();
+ InetSocketAddress addr = new InetSocketAddress("127.0.0.1", 5000);
+ cb.proxy(ProxySelector.of(addr));
+ HttpClient c = cb.build();
+ clients.add(c);
+ checkNonNull(()-> {return c.executorService();});
+ assertTrue(()-> {return c.followRedirects() == HttpClient.Redirect.NEVER;});
+ assertTrue(()-> {return !c.authenticator().isPresent();});
+ }
+
+ static URI accessibleURI() {
+ return URI.create(fileuri);
+ }
+
+ static HttpRequest request() {
+ return HttpRequest.create(accessibleURI())
+ .GET();
+ }
+
+ static void test3() throws Exception {
+ System.out.println("Test 3");
+ reject(()-> {
+ try {
+ HttpRequest r1 = request();
+ HttpResponse resp = r1.response();
+ HttpResponse resp1 = r1.response();
+ } catch (IOException |InterruptedException e) {
+ throw new RuntimeException(e);
+ }
+ }, IllegalStateException.class);
+
+ reject(()-> {
+ try {
+ HttpRequest r1 = request();
+ HttpResponse resp = r1.response();
+ HttpResponse resp1 = r1.responseAsync().get();
+ } catch (IOException |InterruptedException | ExecutionException e) {
+ throw new RuntimeException(e);
+ }
+ }, IllegalStateException.class);
+ reject(()-> {
+ try {
+ HttpRequest r1 = request();
+ HttpResponse resp1 = r1.responseAsync().get();
+ HttpResponse resp = r1.response();
+ } catch (IOException |InterruptedException | ExecutionException e) {
+ throw new RuntimeException(e);
+ }
+ }, IllegalStateException.class);
+ }
+
+ static class Auth extends java.net.Authenticator {
+ int count = 0;
+ @Override
+ protected PasswordAuthentication getPasswordAuthentication() {
+ if (count++ == 0) {
+ return new PasswordAuthentication("user", "passwd".toCharArray());
+ } else {
+ return new PasswordAuthentication("user", "goober".toCharArray());
+ }
+ }
+ int count() {
+ return count;
+ }
+ }
+
+ public static void initServer() throws Exception {
+ String root = System.getProperty ("test.src")+ "/docs";
+ InetSocketAddress addr = new InetSocketAddress (0);
+ s1 = HttpServer.create (addr, 0);
+ if (s1 instanceof HttpsServer) {
+ throw new RuntimeException ("should not be httpsserver");
+ }
+ HttpHandler h = new FileServerHandler(root);
+
+ HttpContext c1 = s1.createContext("/files", h);
+
+ executor = Executors.newCachedThreadPool();
+ s1.setExecutor (executor);
+ s1.start();
+
+ port = s1.getAddress().getPort();
+ System.out.println("HTTP server port = " + port);
+ httproot = "http://127.0.0.1:" + port + "/files/";
+ fileuri = httproot + "foo.txt";
+ }
+}