You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flume.apache.org by es...@apache.org on 2011/08/12 02:48:11 UTC

svn commit: r1156903 - /incubator/flume/branches/flume-728/flume-ng-node/src/test/java/org/apache/flume/node/TestFlumeNode.java

Author: esammer
Date: Fri Aug 12 00:48:10 2011
New Revision: 1156903

URL: http://svn.apache.org/viewvc?rev=1156903&view=rev
Log:
- Use LifecycleState.{START,STOP}_OR_ERROR rather than creating new arrays each time.

Modified:
    incubator/flume/branches/flume-728/flume-ng-node/src/test/java/org/apache/flume/node/TestFlumeNode.java

Modified: incubator/flume/branches/flume-728/flume-ng-node/src/test/java/org/apache/flume/node/TestFlumeNode.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-node/src/test/java/org/apache/flume/node/TestFlumeNode.java?rev=1156903&r1=1156902&r2=1156903&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-node/src/test/java/org/apache/flume/node/TestFlumeNode.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-node/src/test/java/org/apache/flume/node/TestFlumeNode.java Fri Aug 12 00:48:10 2011
@@ -28,15 +28,14 @@ public class TestFlumeNode {
 
     node.start(context);
     boolean reached = LifecycleController.waitForOneOf(node,
-        new LifecycleState[] { LifecycleState.START, LifecycleState.ERROR },
-        5000);
+        LifecycleState.START_OR_ERROR, 5000);
 
     Assert.assertTrue("Matched a known state", reached);
     Assert.assertEquals(LifecycleState.START, node.getLifecycleState());
 
     node.stop(context);
-    reached = LifecycleController.waitForOneOf(node, new LifecycleState[] {
-        LifecycleState.STOP, LifecycleState.ERROR }, 5000);
+    reached = LifecycleController.waitForOneOf(node,
+        LifecycleState.STOP_OR_ERROR, 5000);
 
     Assert.assertTrue("Matched a known state", reached);
     Assert.assertEquals(LifecycleState.STOP, node.getLifecycleState());
@@ -48,8 +47,7 @@ public class TestFlumeNode {
 
     node.start(context);
     boolean reached = LifecycleController.waitForOneOf(node,
-        new LifecycleState[] { LifecycleState.START, LifecycleState.ERROR },
-        5000);
+        LifecycleState.START_OR_ERROR, 5000);
 
     Assert.assertTrue("Matched a known state", reached);
     Assert.assertEquals(LifecycleState.START, node.getLifecycleState());
@@ -59,8 +57,8 @@ public class TestFlumeNode {
     node.getNodeManager().add(n1);
 
     node.stop(context);
-    reached = LifecycleController.waitForOneOf(node, new LifecycleState[] {
-        LifecycleState.STOP, LifecycleState.ERROR }, 5000);
+    reached = LifecycleController.waitForOneOf(node,
+        LifecycleState.STOP_OR_ERROR, 5000);
 
     Assert.assertTrue("Matched a known state", reached);
     Assert.assertEquals(LifecycleState.STOP, node.getLifecycleState());