- ChannelDriverThread now properly detects (separate) source and sink failures, records the exception, and exits cleanly to the ChannelDriver (its parent). - Added a big fat warning about my ugly repurposing of LifecycleState for something that isn't LifecycleAware. I'm gross.

git-svn-id: https://svn.apache.org/repos/asf/incubator/flume/branches/flume-728@1156869 13f79535-47bb-0310-9956-ffa450edef68
- Added unit tests for ChannelDriver / ChannelDriverThread (although we black box test the latter).

git-svn-id: https://svn.apache.org/repos/asf/incubator/flume/branches/flume-728@1156870 13f79535-47bb-0310-9956-ffa450edef68
- Fixed log messages. SLF4J doesn't do the right thing with log(string, object, throwable). - Fixed a bug (in a really gross way) where we didn't close a sink if a source failed to open. - Improved ChannelDriver unit tests to ensure the number of events from a source match those successfully delivered to the sink. - Added tests for both flakey next and append methods in the source and sink respectively.

git-svn-id: https://svn.apache.org/repos/asf/incubator/flume/branches/flume-728@1156871 13f79535-47bb-0310-9956-ffa450edef68
- Made all CounterGroup methods synchronized.

git-svn-id: https://svn.apache.org/repos/asf/incubator/flume/branches/flume-728@1156872 13f79535-47bb-0310-9956-ffa450edef68
- Added LifecycleController methods that block indefinitely.

git-svn-id: https://svn.apache.org/repos/asf/incubator/flume/branches/flume-728@1156873 13f79535-47bb-0310-9956-ffa450edef68
- Allow LifecycleAware methods to throw InterruptedException.

git-svn-id: https://svn.apache.org/repos/asf/incubator/flume/branches/flume-728@1156874 13f79535-47bb-0310-9956-ffa450edef68
- We now block on driver thread start and complain LOUDLY if we can't.

git-svn-id: https://svn.apache.org/repos/asf/incubator/flume/branches/flume-728@1156875 13f79535-47bb-0310-9956-ffa450edef68
- Added ChannelDriver unit tests that mimic long blocking open() / close().

git-svn-id: https://svn.apache.org/repos/asf/incubator/flume/branches/flume-728@1156876 13f79535-47bb-0310-9956-ffa450edef68
- We now block indefinitely in the logical node start() method.

git-svn-id: https://svn.apache.org/repos/asf/incubator/flume/branches/flume-728@1156877 13f79535-47bb-0310-9956-ffa450edef68
- Removed LifecycleAware#transitionTo().

git-svn-id: https://svn.apache.org/repos/asf/incubator/flume/branches/flume-728@1156878 13f79535-47bb-0310-9956-ffa450edef68
- Added a note about error handling and ordering of operations.

git-svn-id: https://svn.apache.org/repos/asf/incubator/flume/branches/flume-728@1156879 13f79535-47bb-0310-9956-ffa450edef68
- Moved node manager implementations into their own package.

git-svn-id: https://svn.apache.org/repos/asf/incubator/flume/branches/flume-728@1156880 13f79535-47bb-0310-9956-ffa450edef68
- Updated TestFlumeNode to pull in AbstractLogicalNodeManager from its new package.

git-svn-id: https://svn.apache.org/repos/asf/incubator/flume/branches/flume-728@1156881 13f79535-47bb-0310-9956-ffa450edef68
- ChannelDriver now properly exposes any exceptions that occur while running. - Added javadoc including blocking and interrupt semantics.

git-svn-id: https://svn.apache.org/repos/asf/incubator/flume/branches/flume-728@1156882 13f79535-47bb-0310-9956-ffa450edef68
- Added javadoc.

git-svn-id: https://svn.apache.org/repos/asf/incubator/flume/branches/flume-728@1156883 13f79535-47bb-0310-9956-ffa450edef68
- Log interrupts received while cleaning up during exceptions.

git-svn-id: https://svn.apache.org/repos/asf/incubator/flume/branches/flume-728@1156884 13f79535-47bb-0310-9956-ffa450edef68
- No longer interrupt the caller of ChannelDriverThread if it's interrupted. - Upgraded the level of a sink open log event from debug to error on intr.

git-svn-id: https://svn.apache.org/repos/asf/incubator/flume/branches/flume-728@1156885 13f79535-47bb-0310-9956-ffa450edef68
- Fixed a bug where we didn't handle interrupts well in start / stop of LogicalNode. Better, but not totally there yet.

git-svn-id: https://svn.apache.org/repos/asf/incubator/flume/branches/flume-728@1156886 13f79535-47bb-0310-9956-ffa450edef68
- Added a (currently failing) unit test of an interrupted open() in LogicalNode.

git-svn-id: https://svn.apache.org/repos/asf/incubator/flume/branches/flume-728@1156887 13f79535-47bb-0310-9956-ffa450edef68
- Refactored to use ChannelDriverThread directly. Not sure this is good, but I wanted to try it.

git-svn-id: https://svn.apache.org/repos/asf/incubator/flume/branches/flume-728@1156888 13f79535-47bb-0310-9956-ffa450edef68