Quadcap Embeddable Server

com/quadcap/io/Test.java

Go to the documentation of this file.

package com.quadcap.io;

/* Copyright 1997 - 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 com.quadcap.util.*;

/**
 * Test cases for various io classes.
 *
 * @author Stan Bailes
 */
public class Test extends com.quadcap.util.Test {
    void testDot(String s) throws IOException {
        ByteArrayOutputStream b1 = new ByteArrayOutputStream();
        DotStuffOutputStream os = new DotStuffOutputStream(b1);
        os.write(s.getBytes());
        os.close();
        String dotrep = b1.toString();

        ByteArrayInputStream b2 = new ByteArrayInputStream(dotrep.getBytes());
        DotStuffInputStream is = new DotStuffInputStream(b2);
        ByteArrayOutputStream b3 = new ByteArrayOutputStream();
        int c;
        while ((c = is.read()) >= 0) { b3.write(c); }
        String act = b3.toString();
        testAssert(s.equals(act));
    }

    public void testDotStuffStreams(String[] args) throws IOException {
        testDot("a\r\n.b\n");
        testDot(".\r\n");
        testDot(
            "hello\r\n.goodbye\r\nlala\r\n\r\n..\r\n\r\n..ar\r\nfoo\r\n.\r\n"
            );

        testDot("");
        testDot(".");
        testDot(".\n");
        testDot("\n");
        testDot("\r\n");
        // XXX This test can't be made to work if we want DotStuffInputStream
        // XXX to be able to handle non-compliant newline-only implementations.
        // XXX pffhht.
        // testDot("\n.\n.\n.\n."); 
    }
    
    public void testLimitedOutputStream(String[] args) {
        ByteArrayOutputStream bos = new ByteArrayOutputStream();
        ByteArrayOutputStream bos2 = new ByteArrayOutputStream();
        LimitedOutputStream los = new LimitedOutputStream(bos, 25);
        boolean hitLimit = false;
        try {
            for (int i = 0; i < 10; i++) {
                bos2.write(Util.bytes("   " + i));
                los.write(Util.bytes("   " + i));
            }
        } catch (IOException e) {
            if (e instanceof LimitExceededException) {
                hitLimit  = true;
                String b1 = bos.toString();
                if (b1.length() != 25) {
                    testError("wrong length: " + b1.length());
                }
                String b2 = bos2.toString().substring(0, 25);
                if (!b1.equals(b2)) {
                    testError("'" + b1 + "' != '" + b2 + "'");
                }
            } else {
                testError("wrong exception: " + e.toString());
                Debug.print(e);
            }
        }
        if (!hitLimit) {
            testError("no exception");
        }
        
    }

    public void testNullOutputStream(String[] args) {
        for (int i = 0; i < 10; i++) {
            NullOutputStream.Null.println("   " + i);
        }
    }

    public void testBase64(String[] args) throws IOException {
        for (int i = 0; i < 5; i++) {
            SaveRestoreStream sr = new SaveRestoreStream();
            OutputStream out = sr.getOutputStream();
            Base64OutputStream bout = new Base64OutputStream(out);
            for (int j = 0; j < i; j++) {
                bout.write(j + 16);
            }
            bout.finish();
            out.close();
            InputStream is = sr.getInputStream();
            Base64InputStream bin = new Base64InputStream(is);
            for (int j = 0; j <= i; j++) {
                writer.println("" + i + ": " + j + ": " + bin.read());
            }
            bin.close();
            sr.close();
        }
    }

    public void testSaveRestore(String[] args) throws IOException {
        for (int size = 1; size < (1 << 16); size <<= 1) {
            SaveRestoreStream so = new SaveRestoreStream(1000);
            OutputStream os = so.getOutputStream();
            for (int i = 0; i < size; i += 4) {
                os.write((i >> 24) & 0xff);
                os.write((i >> 16) & 0xff);
                os.write((i >> 8) & 0xff);
                os.write(i & 0xff);
            }
            InputStream is = so.getInputStream();
            for (int i = 0; i < size; i += 4) {
                int t = is.read();
                t <<= 8; t |= (is.read() & 0xff);
                t <<= 8; t |= (is.read() & 0xff);
                t <<= 8; t |= (is.read() & 0xff);
                testAssert(t == i);
            }
        }
    }

    public void testRecursiveFileIterator(String[] args)
        throws Exception
    {
        FileFilter filter = new FileFilter() {
                public boolean accept(File f) {
                    if (f.isDirectory()) {
                        return !f.getName().equals("CVS");
                    } else {
                        return (f.getName().endsWith(".java"));
                    }
                }
            };
        RecursiveFileIterator f =
            new RecursiveFileIterator(new File("."), filter);
        while (f.hasNext()) {
            File fil = (File)f.next();
            writer.println(fil.getName());
        }
    }
    
    public static void main(String args[]) {
        Test t = new Test();
        t.test(args);
    }

}