You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by ma...@apache.org on 2015/02/10 15:48:12 UTC
incubator-nifi git commit: NIFI-250: Expose number of active threads
in ProcessorNode, ReportingTaskNode
Repository: incubator-nifi
Updated Branches:
refs/heads/NIFI-250 40e250667 -> ea8cb5984
NIFI-250: Expose number of active threads in ProcessorNode, ReportingTaskNode
Project: http://git-wip-us.apache.org/repos/asf/incubator-nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-nifi/commit/ea8cb598
Tree: http://git-wip-us.apache.org/repos/asf/incubator-nifi/tree/ea8cb598
Diff: http://git-wip-us.apache.org/repos/asf/incubator-nifi/diff/ea8cb598
Branch: refs/heads/NIFI-250
Commit: ea8cb59848e5cc75c201ce1b9521aa56eb293674
Parents: 40e2506
Author: Mark Payne <ma...@hotmail.com>
Authored: Tue Feb 10 09:48:01 2015 -0500
Committer: Mark Payne <ma...@hotmail.com>
Committed: Tue Feb 10 09:48:01 2015 -0500
----------------------------------------------------------------------
.../java/org/apache/nifi/controller/ProcessorNode.java | 5 +++++
.../org/apache/nifi/controller/ReportingTaskNode.java | 6 ++++++
.../org/apache/nifi/controller/StandardProcessorNode.java | 10 ++++++++++
.../controller/reporting/AbstractReportingTaskNode.java | 5 +++++
4 files changed, 26 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/ea8cb598/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/controller/ProcessorNode.java
----------------------------------------------------------------------
diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/controller/ProcessorNode.java b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/controller/ProcessorNode.java
index f6786fa..81ef7c0 100644
--- a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/controller/ProcessorNode.java
+++ b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/controller/ProcessorNode.java
@@ -77,4 +77,9 @@ public abstract class ProcessorNode extends AbstractConfiguredComponent implemen
public abstract void setStyle(Map<String, String> style);
+ /**
+ * Returns the number of threads (concurrent tasks) currently being used by this Processor
+ * @return
+ */
+ public abstract int getActiveThreadCount();
}
http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/ea8cb598/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/controller/ReportingTaskNode.java
----------------------------------------------------------------------
diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/controller/ReportingTaskNode.java b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/controller/ReportingTaskNode.java
index 50dd787..76285d1 100644
--- a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/controller/ReportingTaskNode.java
+++ b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/controller/ReportingTaskNode.java
@@ -49,6 +49,12 @@ public interface ReportingTaskNode extends ConfiguredComponent {
ConfigurationContext getConfigurationContext();
boolean isRunning();
+
+ /**
+ * Returns the number of threads (concurrent tasks) currently being used by this ReportingTask
+ * @return
+ */
+ int getActiveThreadCount();
/**
* Indicates the {@link ScheduledState} of this <code>ReportingTask</code>. A
http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/ea8cb598/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardProcessorNode.java
----------------------------------------------------------------------
diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardProcessorNode.java b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardProcessorNode.java
index fe72ae4..af25955 100644
--- a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardProcessorNode.java
+++ b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardProcessorNode.java
@@ -985,6 +985,16 @@ public class StandardProcessorNode extends ProcessorNode implements Connectable
readLock.unlock();
}
}
+
+ @Override
+ public int getActiveThreadCount() {
+ readLock.lock();
+ try {
+ return processScheduler.getActiveThreadCount(this);
+ } finally {
+ readLock.unlock();
+ }
+ }
@Override
public boolean isValid() {
http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/ea8cb598/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/reporting/AbstractReportingTaskNode.java
----------------------------------------------------------------------
diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/reporting/AbstractReportingTaskNode.java b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/reporting/AbstractReportingTaskNode.java
index fa5a621..079ff31 100644
--- a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/reporting/AbstractReportingTaskNode.java
+++ b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/reporting/AbstractReportingTaskNode.java
@@ -91,6 +91,11 @@ public abstract class AbstractReportingTaskNode extends AbstractConfiguredCompon
public boolean isRunning() {
return processScheduler.isScheduled(this) || processScheduler.getActiveThreadCount(this) > 0;
}
+
+ @Override
+ public int getActiveThreadCount() {
+ return processScheduler.getActiveThreadCount(this);
+ }
@Override
public ConfigurationContext getConfigurationContext() {