mirror of https://github.com/apache/nifi.git
0c5b1c27f2
* Simplified and cleaned StandardProcessScheduler.start/stopProcessor methods * Added stop/start operations to ProcessorNode. * Removed unnecessary synchronization blocks related to ScheduledState in favor of enforcing order and idempotency via CAS operations. Those synchronization blocks were causing intermittent deadlocks whenever @OnScheduled blocks indefinitely. * Added support for stopping the service when @OnScheduled operation hangs. * Fixed the order of life-cycle operation invocation ensuring that each operation can *only* be invoked at the appropriate time * Removed unnecessary locks from StandardProcessNode since Atomic variables are used. * Removed calls to @OnStopped from ContinuallyRunningProcessTask while ensuring that procesor's full shut down in implementation of StandardProcessorNode.stop() method. * Removed dead code * Added comprehensive tests suite that covers 95% of Processor's life-cycle operations within the scope of FlowController, StandardProcesssScheduler and StandardProcessNode * Improved and added javadocs on covered operations with detailed explanations. |
||
|---|---|---|
| .. | ||
| src | ||
| .gitignore | ||
| pom.xml | ||