From 23d5587f8a4a4dfa5fb2f5d9497d04733cdfe8df Mon Sep 17 00:00:00 2001 From: antelder Date: Mon, 21 Dec 2009 11:58:17 +0000 Subject: Copy 1.x trunk to branches for start of 1.6 release git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@892786 13f79535-47bb-0310-9956-ffa450edef68 --- .../java/domainmgr/DomainManagerErrorTestCase.java | 342 +++++++++++++++++++++ .../src/test/resources/domain/cloud.composite | 9 + .../resources/domain/cloud/PaymentNode.composite | 13 + .../src/test/resources/domain/domain.composite | 9 + .../src/test/resources/domain/workspace.xml | 8 + 5 files changed, 381 insertions(+) create mode 100644 sca-java-1.x/branches/sca-java-1.6/itest/domainmgr/error/runtest/src/test/java/domainmgr/DomainManagerErrorTestCase.java create mode 100644 sca-java-1.x/branches/sca-java-1.6/itest/domainmgr/error/runtest/src/test/resources/domain/cloud.composite create mode 100644 sca-java-1.x/branches/sca-java-1.6/itest/domainmgr/error/runtest/src/test/resources/domain/cloud/PaymentNode.composite create mode 100644 sca-java-1.x/branches/sca-java-1.6/itest/domainmgr/error/runtest/src/test/resources/domain/domain.composite create mode 100644 sca-java-1.x/branches/sca-java-1.6/itest/domainmgr/error/runtest/src/test/resources/domain/workspace.xml (limited to 'sca-java-1.x/branches/sca-java-1.6/itest/domainmgr/error/runtest/src/test') diff --git a/sca-java-1.x/branches/sca-java-1.6/itest/domainmgr/error/runtest/src/test/java/domainmgr/DomainManagerErrorTestCase.java b/sca-java-1.x/branches/sca-java-1.6/itest/domainmgr/error/runtest/src/test/java/domainmgr/DomainManagerErrorTestCase.java new file mode 100644 index 0000000000..23ffc440ab --- /dev/null +++ b/sca-java-1.x/branches/sca-java-1.6/itest/domainmgr/error/runtest/src/test/java/domainmgr/DomainManagerErrorTestCase.java @@ -0,0 +1,342 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +package domainmgr; + +import java.io.BufferedReader; +import java.io.File; +import java.io.InputStream; +import java.io.InputStreamReader; +import java.io.OutputStream; + +import org.junit.Test; + +/** + * Starts the Romain Manager with a test configuration, then starts + * a test node that reads a deployed composite. The domain manager + * should read and configure the composite and send it to the node + * without detecting or reporting any errors. + */ +public class DomainManagerErrorTestCase { + + private String home = System.getProperty("java.home"); + private String classpath = System.getProperty("java.class.path"); + private Runtime runtime = Runtime.getRuntime(); + private Process domainMgr = null; + private BufferedReader domainErrReader; + private BufferedReader domainOutReader; + private OutputStream domainIn; + + @Test + public void test() throws Exception { + + TestNode paymentNode = null; + + try { + // Start the domain manager process in its own working directory of + // "target/test-classes/domain/" to ensure no interference with the + // node processes. The predefined domain config is copied by mvn + // from the "src/test/resources/domain/" directory. + System.out.println("Starting domain manager"); + String[] domainCommand = { + "" + home + "/bin/java", + "-cp", + "" + classpath + "", + "org.apache.tuscany.sca.node.launcher.DomainManagerLauncher"}; + String userdir = System.getProperty("user.dir"); + domainMgr = runtime.exec(domainCommand, null, new File(userdir + "/target/test-classes/domain/")); + + // Get the new process's stdin, stdout and stderr streams so that we + // can monitor and control execution of the domain manager process. + InputStream domainErr = domainMgr.getErrorStream(); + domainErrReader = new BufferedReader(new InputStreamReader(domainErr)); + InputStream domainOut = domainMgr.getInputStream(); + domainOutReader = new BufferedReader(new InputStreamReader(domainOut)); + domainIn = domainMgr.getOutputStream(); + + // Read startup log output from the domain manager process. The log + // output is written to the process's stderr. + while (true) { + checkDomainOut(); + String line = domainErrReader.readLine(); + if (line == null) { + // reached end of stderr stream before startup completed + throw new IllegalStateException("Error starting Domain Manager process"); + } + System.out.println("DomainMgr.e: " + line); + if (line.contains("SEVERE:")) { + // startup error logged by domain manager process + throw new IllegalStateException("Domain manager reported error: " + line); + } + if (line.contains("INFO: Press 'q' to quit, 'r' to restart.")) { + // domain manager started successfully + System.out.println("Domain manager started successfully"); + break; + } + } + checkDomainOut(); + + // Start the test nodes. Each node runs in its own "target" directory + // to ensure no interference with other processes. + paymentNode = new TestNode("PaymentNode", userdir + "/../payment/target/"); + paymentNode.start(); + + // Stop the test nodes. + paymentNode.stopNode(); + + // Stop the domain manager + stopDomain(); + + } catch (Exception ex) { + + // Error found, so destroy the test node processes and the domain + // manager process so that the test case exits cleanly. + if (paymentNode != null) { + paymentNode.destroyNode(); + } + if (domainMgr != null) { + System.out.println("Destroying domain"); + try { + domainMgr.destroy(); + } catch (Exception e) { + } + } + + // Report the test error. + throw ex; + } + } + + /* + * Stop the test node process. + */ + void stopDomain() throws Exception { + + // Stop the domain manager by sending 'q' to stdin. + System.out.println("Stopping domain manager"); + domainIn.write('q'); + domainIn.flush(); + while (true) { + checkDomainOut(); + String line = domainErrReader.readLine(); + if (line == null) { + // reached end of stderr stream before shutdown completed + throw new IllegalStateException("Error stopping Domain Manager process"); + } + System.out.println("DomainMgr.e: " + line); + if (line.contains("SEVERE:")) { + // shutdown error logged by domain manager process + throw new IllegalStateException("Domain manager reported error: " + line); + } + if (line.contains("INFO: SCA Domain Manager is now stopped.")) { + // domain manager stopped successfully + System.out.println("Domain manager stopped successfully"); + break; + } + } + checkDomainOut(); + + // Wait for domain manager process to end, and check its exit value. + int value = domainMgr.waitFor(); + if (value != 0) { + throw new IllegalStateException("Domain Manager process exit value " + value); + } + domainMgr = null; + } + + /* + * Check stderr for the domain manager process. Called periodically + * to ensure that anything written to stderr is displayed in the test log + * and abort execution if the domain manager has logged any errors. + */ + private void checkDomainErr() throws Exception { + while (domainErrReader.ready()) { + String line = domainErrReader.readLine(); + System.out.println("DomainMgr.e: " + line); + + // This test deliberately causes a domain manager error, so + // don't report a test failure if the expected error shows + // up in the domain manager log. + if (line.contains("SEVERE: Policy Related Exception occured due to : org.apache.tuscany.sca.assembly.builder.impl.PolicyConfigurationException")) { + continue; + } + + if (line.contains("SEVERE:")) { + throw new IllegalStateException("Domain manager reported error: " + line); + } + } + } + + /* + * Check stdout for the domain manager process. Called periodically + * to ensure that anything written to stdout is displayed in the test log. + */ + private void checkDomainOut() throws Exception { + while (domainOutReader.ready()) { + String line = domainOutReader.readLine(); + System.out.println("DomainMgr.o: " + line); + } + } + + /* + * Internal class representing a test node. + */ + private class TestNode { + + String nodeName; + String nodeDir; + BufferedReader nodeErrReader; + BufferedReader nodeOutReader; + OutputStream nodeIn; + Process nodeProcess; + + TestNode(String nodeName, String nodeDir) { + this.nodeName = nodeName; + this.nodeDir = nodeDir; + } + + /* + * Start the test node. + */ + void start() throws Exception { + System.out.println("Starting node " + nodeName); + String[] nodeCommand = { + "" + home + "/bin/java", + "-cp", + "" + classpath + "", + "org.apache.tuscany.sca.node.launcher.NodeLauncher", + "http://localhost:9990/node-config/" + nodeName}; + nodeProcess = runtime.exec(nodeCommand, null, new File(nodeDir)); + + // Get the new process's stdin, stdout and stderr streams so that we + // can monitor and control execution of the test node process. + InputStream nodeErr = nodeProcess.getErrorStream(); + nodeErrReader = new BufferedReader(new InputStreamReader(nodeErr)); + InputStream nodeOut = nodeProcess.getInputStream(); + nodeOutReader = new BufferedReader(new InputStreamReader(nodeOut)); + nodeIn = nodeProcess.getOutputStream(); + + // Read startup log output from the test node process. The log + // output is written to the process's stderr. + boolean firsterror = false; + boolean seconderror = false; + try { + while (true) { + + // The domain manager may throw an exception and hang, so give it + // enough time to do this before we block on the readLine() call. + // A more robust implementation would be to read the domain manager + // output on another thread, which could interrupt the blocked + // readLine() call if the domain manager gets into trouble. + Thread.sleep(100); + checkDomainErr(); + checkDomainOut(); + + checkNodeOut(); + String line = nodeErrReader.readLine(); + if (line == null) { + // reached end of stderr stream before startup completed + throw new IllegalStateException("Error starting node " + nodeName); + } + System.out.println(nodeName + ".e: " + line); + if (line.contains("SEVERE: HTTP Server Error : org.apache.tuscany.sca.assembly.builder.impl.PolicyConfigurationException")) { + // test node received first expected error from the domain + System.out.println("Node " + nodeName + " received first expected error from domain"); + firsterror = true; + continue; + } + if (line.contains("SEVERE: ContributionReadException occured due to : java.io.IOException: Server returned HTTP response code: 500")) { + if (firsterror) { + // test node received second expected error from the domain + System.out.println("Node " + nodeName + " received second expected error from domain"); + seconderror = true; + return; + } + } + if (line.contains("SEVERE:")) { + // startup error logged by test node process + throw new IllegalStateException("Node " + nodeName + " reported error: " + line); + } + if (line.contains("INFO: Press 'q' to quit, 'r' to restart.")) { + // test node started successfully + throw new IllegalStateException("Node " + nodeName + " did not receive expected error from domain"); + } + } + } finally { + checkDomainErr(); + checkDomainOut(); + checkNodeOut(); + } + } + + /* + * Check stderr for the test node process. Called periodically to + * ensure that anything written to stderr is displayed in the test log + * and abort execution if the test node has logged any errors. + */ + void checkNodeErr() throws Exception { + while (nodeErrReader.ready()) { + String line = nodeErrReader.readLine(); + System.out.println(nodeName + ".e: " + line); + if (line.contains("SEVERE:")) { + throw new IllegalStateException("Node " + nodeName + " reported error: " + line); + } + } + } + + /* + * Check stdout for the test node process. Called periodically to + * ensure that anything written to stdout is displayed in the test log. + */ + void checkNodeOut() throws Exception { + while (nodeOutReader.ready()) { + String line = nodeOutReader.readLine(); + System.out.println(nodeName + ".o: " + line); + } + } + + /* + * Stop the test node process. + */ + void stopNode() throws Exception { + // The node did not start, so there is no need to send it a + // "quit" command to shut it down. We just need to make sure + // that the node process has ended cleanly. + + // Wait for test node process to end, and check its exit value. + int value = nodeProcess.waitFor(); + if (value != 1) { + throw new IllegalStateException("Node " + nodeName + " exit value " + value); + } + } + + /* + * Destroy the test node process. + */ + void destroyNode() { + if (nodeProcess != null) { + System.out.println("Destroying node " + nodeName); + try { + nodeProcess.destroy(); + } catch (Exception e) { + } + } + } + } + +} diff --git a/sca-java-1.x/branches/sca-java-1.6/itest/domainmgr/error/runtest/src/test/resources/domain/cloud.composite b/sca-java-1.x/branches/sca-java-1.6/itest/domainmgr/error/runtest/src/test/resources/domain/cloud.composite new file mode 100644 index 0000000000..ca43648169 --- /dev/null +++ b/sca-java-1.x/branches/sca-java-1.6/itest/domainmgr/error/runtest/src/test/resources/domain/cloud.composite @@ -0,0 +1,9 @@ + + + + diff --git a/sca-java-1.x/branches/sca-java-1.6/itest/domainmgr/error/runtest/src/test/resources/domain/cloud/PaymentNode.composite b/sca-java-1.x/branches/sca-java-1.6/itest/domainmgr/error/runtest/src/test/resources/domain/cloud/PaymentNode.composite new file mode 100644 index 0000000000..e61fd4c1a3 --- /dev/null +++ b/sca-java-1.x/branches/sca-java-1.6/itest/domainmgr/error/runtest/src/test/resources/domain/cloud/PaymentNode.composite @@ -0,0 +1,13 @@ + + + + + + + + + diff --git a/sca-java-1.x/branches/sca-java-1.6/itest/domainmgr/error/runtest/src/test/resources/domain/domain.composite b/sca-java-1.x/branches/sca-java-1.6/itest/domainmgr/error/runtest/src/test/resources/domain/domain.composite new file mode 100644 index 0000000000..f03181ecc5 --- /dev/null +++ b/sca-java-1.x/branches/sca-java-1.6/itest/domainmgr/error/runtest/src/test/resources/domain/domain.composite @@ -0,0 +1,9 @@ + + + + diff --git a/sca-java-1.x/branches/sca-java-1.6/itest/domainmgr/error/runtest/src/test/resources/domain/workspace.xml b/sca-java-1.x/branches/sca-java-1.6/itest/domainmgr/error/runtest/src/test/resources/domain/workspace.xml new file mode 100644 index 0000000000..9ee266671d --- /dev/null +++ b/sca-java-1.x/branches/sca-java-1.6/itest/domainmgr/error/runtest/src/test/resources/domain/workspace.xml @@ -0,0 +1,8 @@ + + + + + -- cgit v1.2.3