You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@vxquery.apache.org by pr...@apache.org on 2016/07/19 02:13:56 UTC
vxquery git commit: Fixed an issue with xtest after moving to a
single cluster for testing.
Repository: vxquery
Updated Branches:
refs/heads/master bd27eb084 -> d7cb0a09f
Fixed an issue with xtest after moving to a single cluster for testing.
Project: http://git-wip-us.apache.org/repos/asf/vxquery/repo
Commit: http://git-wip-us.apache.org/repos/asf/vxquery/commit/d7cb0a09
Tree: http://git-wip-us.apache.org/repos/asf/vxquery/tree/d7cb0a09
Diff: http://git-wip-us.apache.org/repos/asf/vxquery/diff/d7cb0a09
Branch: refs/heads/master
Commit: d7cb0a09fc9cc7120a00407320a345081483e675
Parents: bd27eb0
Author: Preston Carman <pr...@apache.org>
Authored: Mon Jul 18 19:13:37 2016 -0700
Committer: Preston Carman <pr...@apache.org>
Committed: Mon Jul 18 19:13:37 2016 -0700
----------------------------------------------------------------------
.../apache/vxquery/xtest/AbstractTestCaseFactory.java | 2 +-
.../org/apache/vxquery/xtest/HTMLFileReporterImpl.java | 10 +++++-----
.../java/org/apache/vxquery/xtest/TestClusterUtil.java | 3 +++
.../src/main/java/org/apache/vxquery/xtest/XTest.java | 13 ++++++++++++-
4 files changed, 21 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/vxquery/blob/d7cb0a09/vxquery-xtest/src/main/java/org/apache/vxquery/xtest/AbstractTestCaseFactory.java
----------------------------------------------------------------------
diff --git a/vxquery-xtest/src/main/java/org/apache/vxquery/xtest/AbstractTestCaseFactory.java b/vxquery-xtest/src/main/java/org/apache/vxquery/xtest/AbstractTestCaseFactory.java
index cf52171..a9fd4a4 100644
--- a/vxquery-xtest/src/main/java/org/apache/vxquery/xtest/AbstractTestCaseFactory.java
+++ b/vxquery-xtest/src/main/java/org/apache/vxquery/xtest/AbstractTestCaseFactory.java
@@ -83,7 +83,7 @@ public abstract class AbstractTestCaseFactory {
}
private static Set<String> getPreviousTests(String previousTestResults) {
- Set<String> tests = new LinkedHashSet<String>();
+ Set<String> tests = new LinkedHashSet<>();
try {
BufferedReader br = new BufferedReader(new FileReader(previousTestResults));
String line;
http://git-wip-us.apache.org/repos/asf/vxquery/blob/d7cb0a09/vxquery-xtest/src/main/java/org/apache/vxquery/xtest/HTMLFileReporterImpl.java
----------------------------------------------------------------------
diff --git a/vxquery-xtest/src/main/java/org/apache/vxquery/xtest/HTMLFileReporterImpl.java b/vxquery-xtest/src/main/java/org/apache/vxquery/xtest/HTMLFileReporterImpl.java
index d9e85e3..d64fcec 100644
--- a/vxquery-xtest/src/main/java/org/apache/vxquery/xtest/HTMLFileReporterImpl.java
+++ b/vxquery-xtest/src/main/java/org/apache/vxquery/xtest/HTMLFileReporterImpl.java
@@ -76,12 +76,12 @@ public class HTMLFileReporterImpl implements ResultReporter {
++userErrors;
} else {
++internalErrors;
- Integer count = exDistribution.get(result.error.getClass());
- if (count == null) {
- count = 0;
+ Integer internalCount = exDistribution.get(result.error.getClass());
+ if (internalCount == null) {
+ internalCount = 0;
}
- count++;
- exDistribution.put(result.error.getClass(), count);
+ internalCount++;
+ exDistribution.put(result.error.getClass(), internalCount);
}
}
Integer stCount = stDistribution.get(result.state);
http://git-wip-us.apache.org/repos/asf/vxquery/blob/d7cb0a09/vxquery-xtest/src/main/java/org/apache/vxquery/xtest/TestClusterUtil.java
----------------------------------------------------------------------
diff --git a/vxquery-xtest/src/main/java/org/apache/vxquery/xtest/TestClusterUtil.java b/vxquery-xtest/src/main/java/org/apache/vxquery/xtest/TestClusterUtil.java
index 9f5bb76..75dce1b 100644
--- a/vxquery-xtest/src/main/java/org/apache/vxquery/xtest/TestClusterUtil.java
+++ b/vxquery-xtest/src/main/java/org/apache/vxquery/xtest/TestClusterUtil.java
@@ -35,6 +35,9 @@ public class TestClusterUtil {
private static String ccHost = "localhost";
private static String nodeId = "nc1";
+ private TestClusterUtil() {
+ }
+
public static CCConfig createCCConfig() throws UnknownHostException {
String publicAddress = InetAddress.getLocalHost().getHostAddress();
CCConfig ccConfig = new CCConfig();
http://git-wip-us.apache.org/repos/asf/vxquery/blob/d7cb0a09/vxquery-xtest/src/main/java/org/apache/vxquery/xtest/XTest.java
----------------------------------------------------------------------
diff --git a/vxquery-xtest/src/main/java/org/apache/vxquery/xtest/XTest.java b/vxquery-xtest/src/main/java/org/apache/vxquery/xtest/XTest.java
index 17dea60..fa07d9b 100644
--- a/vxquery-xtest/src/main/java/org/apache/vxquery/xtest/XTest.java
+++ b/vxquery-xtest/src/main/java/org/apache/vxquery/xtest/XTest.java
@@ -16,9 +16,12 @@
*/
package org.apache.vxquery.xtest;
+import org.apache.hyracks.control.cc.ClusterControllerService;
+import org.apache.hyracks.control.nc.NodeControllerService;
import org.mortbay.jetty.Server;
import java.io.File;
+import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutorService;
@@ -33,6 +36,8 @@ public class XTest {
private TestRunnerFactory trf;
private int count;
private int finishCount;
+ private static NodeControllerService nc;
+ private static ClusterControllerService cc;
XTest(XTestOptions opts) {
this.opts = opts;
@@ -76,6 +81,8 @@ public class XTest {
}
}
});
+ cc = TestClusterUtil.startCC();
+ nc = TestClusterUtil.startNC();
trf = new TestRunnerFactory(opts);
trf.registerReporters(reporters);
TestCaseFactory tcf = new TestCaseFactory(trf, eSvc, opts);
@@ -97,10 +104,14 @@ public class XTest {
r.close();
}
try {
+ TestClusterUtil.stopCluster(cc, nc);
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ try {
eSvc.awaitTermination(opts.keepalive, TimeUnit.MILLISECONDS);
} finally {
try {
-
if (server != null) {
server.stop();
}