brooklyn-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From henev...@apache.org
Subject [06/11] git commit: Convert Groovy to Java
Date Fri, 25 Jul 2014 17:57:02 GMT
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 <svetoslav.neykov@cloudsoftcorp.com>
Authored: Fri Jul 25 09:50:31 2014 +0300
Committer: Svetoslav Neykov <svetoslav.neykov@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());
+    }
+
+}


Mime
View raw message