B6361557.java revision 0
0N/A/*
0N/A * Copyright 2006 Sun Microsystems, Inc. All Rights Reserved.
0N/A * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
0N/A *
0N/A * This code is free software; you can redistribute it and/or modify it
0N/A * under the terms of the GNU General Public License version 2 only, as
0N/A * published by the Free Software Foundation.
0N/A *
0N/A * This code is distributed in the hope that it will be useful, but WITHOUT
0N/A * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
0N/A * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
0N/A * version 2 for more details (a copy is included in the LICENSE file that
0N/A * accompanied this code).
0N/A *
0N/A * You should have received a copy of the GNU General Public License version
0N/A * 2 along with this work; if not, write to the Free Software Foundation,
0N/A * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
0N/A *
0N/A * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
0N/A * CA 95054 USA or visit www.sun.com if you need additional information or
0N/A * have any questions.
0N/A */
0N/A
0N/A/**
0N/A * @test
0N/A * @bug 6361557
0N/A * @summary Lightweight HTTP server quickly runs out of file descriptors on Linux
0N/A */
0N/A
0N/Aimport com.sun.net.httpserver.*;
0N/A
0N/Aimport java.util.*;
0N/Aimport java.util.concurrent.*;
0N/Aimport java.io.*;
0N/Aimport java.nio.*;
0N/Aimport java.nio.channels.*;
0N/Aimport java.net.*;
0N/Aimport java.security.*;
0N/Aimport java.security.cert.*;
0N/Aimport javax.net.ssl.*;
0N/A
0N/A/**
0N/A * The test simply opens 10,000 separate connections
0N/A * and invokes one http request on each. The client does
0N/A * not close any sockets until after they are closed
0N/A * by the server. This verifies the basic ability
0N/A * of the server to manage a reasonable number of connections
0N/A */
0N/Apublic class B6361557 {
0N/A
0N/A public static boolean error = false;
0N/A
0N/A static class Handler implements HttpHandler {
0N/A int invocation = 1;
0N/A public void handle (HttpExchange t)
0N/A throws IOException
0N/A {
0N/A InputStream is = t.getRequestBody();
0N/A Headers map = t.getRequestHeaders();
0N/A Headers rmap = t.getResponseHeaders();
0N/A while (is.read () != -1) ;
0N/A is.close();
0N/A t.sendResponseHeaders (200, -1);
0N/A t.close();
0N/A }
0N/A }
0N/A
0N/A public static void main (String[] args) throws Exception {
0N/A Handler handler = new Handler();
0N/A InetSocketAddress addr = new InetSocketAddress (0);
0N/A HttpServer server = HttpServer.create (addr, 0);
0N/A HttpContext ctx = server.createContext ("/test", handler);
0N/A
0N/A ExecutorService executor = Executors.newCachedThreadPool();
0N/A server.setExecutor (executor);
0N/A server.start ();
0N/A
0N/A final int NUM = 10000;
0N/A ByteBuffer buf = ByteBuffer.allocate (4096);
0N/A InetSocketAddress destaddr = new InetSocketAddress (
0N/A "127.0.0.1", server.getAddress().getPort()
0N/A );
0N/A System.out.println ("destaddr " + destaddr);
0N/A
0N/A Selector selector = Selector.open ();
0N/A int i = 0;
0N/A while (true) {
0N/A i ++;
0N/A int selres = selector.select (1);
0N/A Set<SelectionKey> selkeys = selector.selectedKeys();
0N/A for (SelectionKey key : selkeys) {
0N/A if (key.isReadable()) {
0N/A SocketChannel chan = (SocketChannel)key.channel();
0N/A buf.clear();
0N/A try {
0N/A int x = chan.read (buf);
0N/A if (x == -1) {
0N/A chan.close();
0N/A }
0N/A } catch (IOException e) {}
0N/A }
0N/A }
0N/A if (i< NUM) {
0N/A SocketChannel schan = SocketChannel.open (destaddr);
0N/A String cmd = "GET /test/foo.html HTTP/1.1\r\nContent-length: 0\r\n\r\n";
0N/A buf.rewind ();
0N/A buf.put (cmd.getBytes());
0N/A buf.flip();
0N/A int c = 0;
0N/A while (buf.remaining() > 0) {
0N/A c += schan.write (buf);
0N/A }
0N/A schan.configureBlocking (false);
0N/A schan.register (selector, SelectionKey.OP_READ, null);
0N/A } else {
0N/A System.out.println ("Finished clients");
0N/A server.stop (1);
0N/A executor.shutdown ();
0N/A return;
0N/A }
0N/A }
0N/A }
0N/A}