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:47:16 UTC

svn commit: r1156887 - /incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/core/TestLogicalNode.java

Author: esammer
Date: Fri Aug 12 00:47:16 2011
New Revision: 1156887

URL: http://svn.apache.org/viewvc?rev=1156887&view=rev
Log:
- Added a (currently failing) unit test of an interrupted open() in LogicalNode.

Modified:
    incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/core/TestLogicalNode.java

Modified: incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/core/TestLogicalNode.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/core/TestLogicalNode.java?rev=1156887&r1=1156886&r2=1156887&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/core/TestLogicalNode.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/core/TestLogicalNode.java Fri Aug 12 00:47:16 2011
@@ -6,7 +6,6 @@ import java.util.concurrent.atomic.Atomi
 import org.apache.flume.lifecycle.LifecycleController;
 import org.apache.flume.lifecycle.LifecycleException;
 import org.apache.flume.lifecycle.LifecycleState;
-import org.apache.flume.sink.LoggerSink;
 import org.apache.flume.sink.NullSink;
 import org.apache.flume.source.SequenceGeneratorSource;
 import org.junit.Assert;
@@ -28,7 +27,7 @@ public class TestLogicalNode {
 
     node.setName("test-node-n1");
     node.setSource(new SequenceGeneratorSource());
-    node.setSink(new LoggerSink());
+    node.setSink(new NullSink());
   }
 
   @Test
@@ -52,6 +51,28 @@ public class TestLogicalNode {
   }
 
   @Test
+  public void testInterruptStart() throws LifecycleException,
+      InterruptedException {
+    Context context = new Context();
+
+    Thread.currentThread().interrupt();
+    node.start(context);
+    boolean reached = LifecycleController.waitForOneOf(node,
+        new LifecycleState[] { LifecycleState.START, LifecycleState.ERROR },
+        5000);
+
+    Assert.assertTrue("Matched a lifecycle state", reached);
+    Assert.assertEquals(LifecycleState.START, node.getLifecycleState());
+
+    node.stop(context);
+    reached = LifecycleController.waitForOneOf(node, new LifecycleState[] {
+        LifecycleState.STOP, LifecycleState.ERROR }, 5000);
+
+    Assert.assertTrue("Matched a lifecycle state", reached);
+    Assert.assertEquals(LifecycleState.STOP, node.getLifecycleState());
+  }
+
+  @Test
   public void testMultipleNodes() throws LifecycleException,
       InterruptedException {