Quadcap Embeddable Server

com/quadcap/http/server22/Test.java

Go to the documentation of this file.

package com.quadcap.http.server22;

/* Copyright 1998 - 2003 Quadcap Software.  All rights reserved.
 *
 * This software is distributed under the Quadcap Free Software License.
 * This software may be used or modified for any purpose, personal or
 * commercial.  Open Source redistributions are permitted.  Commercial
 * redistribution of larger works derived from, or works which bundle
 * this software requires a "Commercial Redistribution License"; see
 * http://www.quadcap.com/purchase.
 *
 * Redistributions qualify as "Open Source" under  one of the following terms:
 *   
 *    Redistributions are made at no charge beyond the reasonable cost of
 *    materials and delivery.
 *
 *    Redistributions are accompanied by a copy of the Source Code or by an
 *    irrevocable offer to provide a copy of the Source Code for up to three
 *    years at the cost of materials and delivery.  Such redistributions
 *    must allow further use, modification, and redistribution of the Source
 *    Code under substantially the same terms as this license.
 *
 * Redistributions of source code must retain the copyright notices as they
 * appear in each source code file, these license terms, and the
 * disclaimer/limitation of liability set forth as paragraph 6 below.
 *
 * Redistributions in binary form must reproduce this Copyright Notice,
 * these license terms, and the disclaimer/limitation of liability set
 * forth as paragraph 6 below, in the documentation and/or other materials
 * provided with the distribution.
 *
 * The Software is provided on an "AS IS" basis.  No warranty is
 * provided that the Software is free of defects, or fit for a
 * particular purpose.  
 *
 * Limitation of Liability. Quadcap Software shall not be liable
 * for any damages suffered by the Licensee or any third party resulting
 * from use of the Software.
 */

import java.io.*;
import java.net.Socket;

import com.quadcap.util.Debug;
import com.quadcap.util.Util;

/**
 * A handy little client program for simple server testing.
 *
 * @author Stan Bailes
 */
public class Test extends com.quadcap.util.Test {
    public Test() {
        super();
    }
    
    static byte[] delims = { 0x0d, 0x0a, 0x0d, 0x0a };

    public static byte[] readStream(InputStream is) throws IOException {
        ByteArrayOutputStream bos = new ByteArrayOutputStream();

        int state = 4;
        int cnt = 0;
        while (state < 4) {
            int c = is.read();
            if (c < 0) {
                throw new IOException("unexpected eof in message headers");
            }
            if (delims[state] == c) state++;
            else if (delims[0] == c) state = 1;
            else state = 0;
        }

        byte[] buf = new byte[1024];
        while ((cnt = is.read(buf)) > 0) {
            bos.write(buf, 0, cnt);
        }
        return bos.toByteArray();
    }

    public static byte[] fetch(String url) throws Exception {
        Debug.println(3, "Fetch: " + url);
        if (url.indexOf("http://") != 0) {
            System.err.println("Bad url (protocol): " + url);
            return null;
        }
        url = url.substring(7);
        int idx = url.indexOf('/');
        if (idx <= 0) {
            System.err.println("Bad url (host): " + url);
            return null;
        }
        String host = url.substring(0, idx);
        String name = url.substring(idx);
        idx = host.indexOf(':');
        int port = 80;
        if (idx >= 0) {
            port = Integer.parseInt(host.substring(idx+1));
            host = host.substring(0, idx);
        }
        Socket s = new Socket(host, port);

        OutputStream os = s.getOutputStream();
        BufferedOutputStream bos = new BufferedOutputStream(os);
        
        bos.write(("GET " + name + " HTTP/1.0\r\n\r\n").getBytes());
        bos.flush();

        InputStream is = s.getInputStream();
        BufferedInputStream bis = new BufferedInputStream(is);
        byte[] doc = readStream(bis);
        os.close();
        is.close();
        s.close();
        return doc;
    }

    public void testFetch(String args[]) {
        int cnt = Util.intProperty("count", 100);
        String url = System.getProperty("url");
        if (cnt > 10) {
            try {
                fetch(url);
            } catch (Exception e) {
                Debug.print(e);
            }
        }
        
        long start = System.currentTimeMillis();
        try {
            for (int i = 0; i < cnt; i++) {
                fetch(url);
            }
        } catch (Exception e) {
            Debug.print(e);
        }
        long end = System.currentTimeMillis();
        long elap = end - start;
        double fps = ((double)cnt) / (((double)elap) / 1000.0);
        
        System.out.println("elapsed: " + (end - start) + " ms, " +
                           fps + " pages/sec");
    }
            

    public static void main(String args[]) {
        Test test = new Test();
        test.test(args);
    }
}