cldctckcommand.java

来自「cqME :java framework for TCK test.」· Java 代码 · 共 130 行

/*
 * $Id$
 *
 * Copyright 1996-2007 Sun Microsystems, Inc. All Rights Reserved.
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER
 *
 * This program 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 program 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 at /legal/license.txt).
 *
 * 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 Sun Microsystems, Inc., 4150 Network Circle, Santa
 * Clara, CA 95054 or visit www.sun.com if you need additional
 * information or have any questions.
 *
 */

package com.sun.tck.cldc.javatest;

import java.io.PrintWriter;
import com.sun.javatest.Command;
import com.sun.javatest.Status;
import com.sun.tck.cldc.javatest.util.UTFConverter;
import com.sun.tck.cldc.communication.TestResultListener;
import com.sun.tck.cldc.communication.TestBundle;

public class CldcTCKCommand extends Command implements TestResultListener {

    private byte[] data = null;
    private boolean started = false;
    private boolean vmExited = false;

    public synchronized void passBundleStarted(byte[] req) {
        started = true;
        notify();
    }

    public synchronized void passTestResult(byte[] req, byte[] res) {
        data = res;
        notify();
    }

    public synchronized void passVMExitResult(byte[] req) {
        data = req;
        vmExited = true;
        notify();
    }

    public Status run(String[] args, PrintWriter log,
            PrintWriter ref) {
        TestBundle currentBundle = null;
        try {
            currentBundle = TestBundler.getTestBundler().dispatchTest(
                    args, this);
        } catch (RuntimeException t) {
            t.printStackTrace(log);
            return Status.error("Error while bundling the test. "
                    + t.toString());
        }

        // wait bundle starting
        try {
            synchronized (this) {
                while (!started) {
                    wait();
                }
            }
        } catch (InterruptedException e) {
            e.printStackTrace(log);
            currentBundle.setInterrupted();
            return Status.error("Interrupted");
        }
        // bundle started
        // set an alarm (see CldcTCKScript)
        synchronized(Thread.currentThread()) { 
            Thread.currentThread().notifyAll();
        }

        // wait test result
        try {
            synchronized (this) {
                while (data == null) {
                    wait();
                }
            }
        }
        catch (InterruptedException e) {
            e.printStackTrace(log);
            currentBundle.setInterrupted();
            return Status.error("Interrupted (timed out?)");
        }
        String[] res = UTFConverter.bytesToStrings(data);
        if ("".equals(res[0])) {
            return Status.error("Communication error: " + res[1]);
        }
        if (!args[0].equals(res[0])) {
            return Status.error("Test execution synchronization error: "
                    + "expected test results for " + args[0]
                    + ", but received test results for " + res[0]
                    + ". Possible reason: Incorrectly configured parallel test"
                    + " execution.");
        }
        if (vmExited) {
            return Status.failed("Abnormal VM termination");
        }
        // parsing result
        // res[1] - status
        // res[2] - log
        // res[3] - ref
        log.print(res[2]);
        log.flush();
        ref.print(res[3]);
        ref.flush();
        return Status.parse(res[1]);
    }


}