svn commit: r1156877 - /incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/core/LogicalNode.java

[es...@apache.org]

Author: esammer
Date: Fri Aug 12 00:46:47 2011
New Revision: 1156877

URL: http://svn.apache.org/viewvc?rev=1156877&view=rev
Log:
- We now block indefinitely in the logical node start() method.

Modified:
    incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/core/LogicalNode.java

Modified: incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/core/LogicalNode.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/core/LogicalNode.java?rev=1156877&r1=1156876&r2=1156877&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/core/LogicalNode.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/core/LogicalNode.java Fri Aug 12 00:46:47 2011
@@ -27,7 +27,9 @@ public class LogicalNode implements Life
   }
 
   @Override
-  public void start(Context context) throws LifecycleException {
+  public void start(Context context) throws LifecycleException,
+      InterruptedException {
+
     logger.info("Starting logical node:{}", this);
 
     Preconditions.checkState(name != null, "Logical node name can not be null");
@@ -55,7 +57,7 @@ public class LogicalNode implements Life
 
     try {
       complete = LifecycleController.waitForOneOf(driver, new LifecycleState[] {
-          LifecycleState.STOP, LifecycleState.ERROR }, 10000);
+          LifecycleState.STOP, LifecycleState.ERROR });
     } catch (InterruptedException e) {
       logger.debug("Interrupted while waiting for the driver to stop.");
       complete = false;