You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@brooklyn.apache.org by he...@apache.org on 2014/07/25 19:57:02 UTC
[06/11] git commit: Convert Groovy to Java
Convert Groovy to Java
Project: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/commit/3f5cfc3e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/tree/3f5cfc3e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/diff/3f5cfc3e
Branch: refs/heads/master
Commit: 3f5cfc3ec48b988fa3264be2d6f91bd08e86b197
Parents: 8030224
Author: Svetoslav Neykov <sv...@cloudsoftcorp.com>
Authored: Fri Jul 25 09:50:31 2014 +0300
Committer: Svetoslav Neykov <sv...@cloudsoftcorp.com>
Committed: Fri Jul 25 10:50:57 2014 +0300
----------------------------------------------------------------------
.../qa/longevity/MonitorUtilsTest.groovy | 126 ------------------
.../brooklyn/qa/longevity/MonitorUtilsTest.java | 130 +++++++++++++++++++
2 files changed, 130 insertions(+), 126 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/blob/3f5cfc3e/usage/qa/src/test/java/brooklyn/qa/longevity/MonitorUtilsTest.groovy
----------------------------------------------------------------------
diff --git a/usage/qa/src/test/java/brooklyn/qa/longevity/MonitorUtilsTest.groovy b/usage/qa/src/test/java/brooklyn/qa/longevity/MonitorUtilsTest.groovy
deleted file mode 100644
index f60b68f..0000000
--- a/usage/qa/src/test/java/brooklyn/qa/longevity/MonitorUtilsTest.groovy
+++ /dev/null
@@ -1,126 +0,0 @@
-/*
- * 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 brooklyn.qa.longevity
-
-import static org.testng.Assert.*;
-
-
-import org.testng.annotations.Test
-
-import com.google.common.base.Charsets
-import com.google.common.base.Strings
-import com.google.common.collect.ImmutableMap
-import com.google.common.io.Files
-
-
-import brooklyn.qa.longevity.MonitorUtils;
-import brooklyn.qa.longevity.MonitorUtilsTest;
-
-class MonitorUtilsTest {
-
- @Test(enabled=false, groups="UNIX") // Demonstrates that process.waitFor() hangs for big output streams
- public void testGroovyExecuteAndWaitFor() {
- String bigstr = Strings.repeat("a", 100000)
- def process = "echo $bigstr".execute()
- process.waitFor()
- String out = process.text
- assertTrue(out.contains(bigstr), "out.size="+out.length())
- }
-
- @Test(groups="UNIX")
- public void testGroovyExecuteAndWaitForConsumingOutputStream() {
- String bigstr = Strings.repeat("a", 100000)
- def process = "echo $bigstr".execute()
- String out = MonitorUtils.waitFor(process)
- assertTrue(out.contains(bigstr), "out.size="+out.length())
- }
-
- @Test(groups="UNIX")
- public void testFindOwnPid() {
- int ownpid = MonitorUtils.findOwnPid()
- assertTrue(ownpid > 0, "ownpid=$ownpid")
- assertTrue(MonitorUtils.isPidRunning(ownpid, "java"),"java is not running")
- }
-
- @Test(groups="UNIX")
- public void testIsPidRunning() {
- int usedPid = MonitorUtils.findOwnPid()
-
- // Find a pid that is in not in use
- // Don't count upwards as that is more likely to be the next pid to be allocated leading to non-deterministic failures!
- // 10000 is a conservative estimate of a legal large pid (/proc/sys/kernel/pid_max gives the real max)
- def process = MonitorUtils.exec("ps ax")
- String out = MonitorUtils.waitFor(process)
- int unusedPid = 10000;
- while (out.contains(""+unusedPid)) {
- unusedPid--;
- }
- if (unusedPid <= 0) throw new IllegalStateException("No unused pid found in the range 1-10000");
-
- assertTrue(MonitorUtils.isPidRunning(usedPid))
- assertFalse(MonitorUtils.isPidRunning(unusedPid))
- assertFalse(MonitorUtils.isPidRunning(1234567)) // too large
- }
-
- @Test(groups="UNIX")
- public void testGetRunningPids() {
- int ownpid = MonitorUtils.findOwnPid()
-
- List<Integer> javapids = MonitorUtils.getRunningPids("java")
-
- assertTrue(javapids.contains(ownpid), "javapids="+javapids+"; ownpid="+ownpid)
- }
-
- @Test
- public void testIsUrlUp() {
- assertFalse(MonitorUtils.isUrlUp(new URL("http://localhost/thispathdoesnotexist")))
- }
-
- @Test(groups="UNIX")
- public void testSearchLog() {
- String fileContents = "line1\nline2\nline3\n"
- File file = File.createTempFile("monitorUtilsTest.testSearchLog", ".txt")
- Files.write(fileContents, file, Charsets.UTF_8)
-
- try {
- assertEquals(MonitorUtils.searchLog(file, "line1"), ["line1"])
- assertEquals(MonitorUtils.searchLog(file, "line1|line2"), ["line1", "line2"])
- assertEquals(MonitorUtils.searchLog(file, "textnotthere"), [])
- assertEquals(MonitorUtils.searchLog(file, "line"), ["line1", "line2", "line3"])
- } finally {
- file.delete()
- }
- }
-
- @Test(groups="Integration")
- public void testMemoryUsage() {
- int ownpid = MonitorUtils.findOwnPid()
-
- MonitorUtils.MemoryUsage memUsage = MonitorUtils.getMemoryUsage(ownpid)
- assertTrue(memUsage.totalInstances > 0, memUsage.toString())
- assertTrue(memUsage.totalMemoryBytes > 0, memUsage.toString())
- assertEquals(memUsage.getInstanceCounts(), Collections.emptyMap())
-
- MonitorUtils.MemoryUsage memUsage2 = MonitorUtils.getMemoryUsage(ownpid, MonitorUtilsTest.class.getCanonicalName(),0)
- assertEquals(memUsage2.getInstanceCounts(), ImmutableMap.of(MonitorUtilsTest.class.getCanonicalName(), 1))
-
- MonitorUtils.MemoryUsage memUsage3 = MonitorUtils.getMemoryUsage(ownpid, MonitorUtilsTest.class.getCanonicalName(), 2)
- assertEquals(memUsage3.getInstanceCounts(), Collections.emptyMap())
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/blob/3f5cfc3e/usage/qa/src/test/java/brooklyn/qa/longevity/MonitorUtilsTest.java
----------------------------------------------------------------------
diff --git a/usage/qa/src/test/java/brooklyn/qa/longevity/MonitorUtilsTest.java b/usage/qa/src/test/java/brooklyn/qa/longevity/MonitorUtilsTest.java
new file mode 100644
index 0000000..c62aaef
--- /dev/null
+++ b/usage/qa/src/test/java/brooklyn/qa/longevity/MonitorUtilsTest.java
@@ -0,0 +1,130 @@
+/*
+ * 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 brooklyn.qa.longevity;
+
+import static org.testng.Assert.assertEquals;
+import static org.testng.Assert.assertFalse;
+import static org.testng.Assert.assertTrue;
+import static org.testng.Assert.fail;
+
+import java.io.File;
+import java.net.URL;
+import java.util.Collections;
+import java.util.List;
+
+import org.testng.annotations.Test;
+
+import brooklyn.util.text.Strings;
+
+import com.google.common.base.Charsets;
+import com.google.common.collect.ImmutableMap;
+import com.google.common.io.Files;
+
+public class MonitorUtilsTest {
+
+ @Test(enabled=false, groups="UNIX") // Demonstrates that process.waitFor() hangs for big output streams
+ public void testExecuteAndWaitFor() throws Exception {
+ String bigstr = Strings.repeat("a", 100000);
+ Process process = MonitorUtils.exec("echo " + bigstr);
+ process.waitFor();
+ fail();
+ }
+
+ @Test(groups="UNIX")
+ public void testExecuteAndWaitForConsumingOutputStream() {
+ String bigstr = Strings.repeat("a", 100000);
+ Process process = MonitorUtils.exec("echo " + bigstr);
+ String out = MonitorUtils.waitFor(process);
+ assertTrue(out.contains(bigstr), "out.size="+out.length());
+ }
+
+ @Test(groups="UNIX")
+ public void testFindOwnPid() throws Exception {
+ int ownpid = MonitorUtils.findOwnPid();
+ assertTrue(ownpid > 0, "ownpid=$ownpid");
+ assertTrue(MonitorUtils.isPidRunning(ownpid, "java"),"java is not running");
+ }
+
+ @Test(groups="UNIX")
+ public void testIsPidRunning() throws Exception {
+ int usedPid = MonitorUtils.findOwnPid();
+
+ // Find a pid that is in not in use
+ // Don't count upwards as that is more likely to be the next pid to be allocated leading to non-deterministic failures!
+ // 10000 is a conservative estimate of a legal large pid (/proc/sys/kernel/pid_max gives the real max)
+ Process process = MonitorUtils.exec("ps ax");
+ String out = MonitorUtils.waitFor(process);
+ int unusedPid = 10000;
+ while (out.contains(""+unusedPid)) {
+ unusedPid--;
+ }
+ if (unusedPid <= 0) throw new IllegalStateException("No unused pid found in the range 1-10000");
+
+ assertTrue(MonitorUtils.isPidRunning(usedPid));
+ assertFalse(MonitorUtils.isPidRunning(unusedPid));
+ assertFalse(MonitorUtils.isPidRunning(1234567)); // too large
+ }
+
+ @Test(groups="UNIX")
+ public void testGetRunningPids() throws Exception {
+ int ownpid = MonitorUtils.findOwnPid();
+
+ List<Integer> javapids = MonitorUtils.getRunningPids("java");
+
+ assertTrue(javapids.contains(ownpid), "javapids="+javapids+"; ownpid="+ownpid);
+ }
+
+ @Test
+ public void testIsUrlUp() throws Exception {
+ assertFalse(MonitorUtils.isUrlUp(new URL("http://localhost/thispathdoesnotexist")));
+ }
+
+ @Test(groups="UNIX")
+ public void testSearchLog() throws Exception {
+ String fileContents = "line1\nline2\nline3\n";
+ File file = File.createTempFile("monitorUtilsTest.testSearchLog", ".txt");
+ Files.write(fileContents, file, Charsets.UTF_8);
+
+ try {
+ assertEquals(MonitorUtils.searchLog(file, "line1"), Arrays.asList("line1"));
+ assertEquals(MonitorUtils.searchLog(file, "line1|line2"), Arrays.asList("line1", "line2"));
+ assertEquals(MonitorUtils.searchLog(file, "textnotthere"), Collections.emptyList());
+ assertEquals(MonitorUtils.searchLog(file, "line"), Arrays.asList("line1", "line2", "line3"));
+ } finally {
+ file.delete();
+ }
+ }
+
+ @Test(groups="Integration")
+ public void testMemoryUsage() throws Exception {
+ int ownpid = MonitorUtils.findOwnPid();
+
+ MonitorUtils.MemoryUsage memUsage = MonitorUtils.getMemoryUsage(ownpid);
+ assertTrue(memUsage.totalInstances > 0, memUsage.toString());
+ assertTrue(memUsage.totalMemoryBytes > 0, memUsage.toString());
+ assertEquals(memUsage.getInstanceCounts(), Collections.emptyMap());
+
+ MonitorUtils.MemoryUsage memUsage2 = MonitorUtils.getMemoryUsage(ownpid, MonitorUtilsTest.class.getCanonicalName(),0);
+ assertEquals(memUsage2.getInstanceCounts(), ImmutableMap.of(MonitorUtilsTest.class.getCanonicalName(), 1));
+
+ MonitorUtils.MemoryUsage memUsage3 = MonitorUtils.getMemoryUsage(ownpid, MonitorUtilsTest.class.getCanonicalName(), 2);
+ assertEquals(memUsage3.getInstanceCounts(), Collections.emptyMap());
+ }
+
+}