Repository: nifi Updated Branches: refs/heads/master 98f5a1ab7 -> ee87f33ce
Fixing check-style violation in StandardFlowFileQueue Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/ee87f33c Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/ee87f33c Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/ee87f33c Branch: refs/heads/master Commit: ee87f33ce7aada9f05f43cb3b00f2fab0793cd82 Parents: 98f5a1a Author: Bryan Bende <[email protected]> Authored: Fri Nov 6 09:10:10 2015 -0500 Committer: Bryan Bende <[email protected]> Committed: Fri Nov 6 09:10:10 2015 -0500 ---------------------------------------------------------------------- .../java/org/apache/nifi/controller/StandardFlowFileQueue.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/ee87f33c/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardFlowFileQueue.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardFlowFileQueue.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardFlowFileQueue.java index 0b3c661..ae991c8 100644 --- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardFlowFileQueue.java +++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardFlowFileQueue.java @@ -1233,8 +1233,8 @@ public final class StandardFlowFileQueue implements FlowFileQueue { } private void logIfNegative(final FlowFileQueueSize original, final FlowFileQueueSize newSize, final String counterName) { - if (newSize.activeQueueBytes < 0 || newSize.activeQueueCount < 0 || newSize.swappedBytes < 0 || newSize.swappedCount < 0 || - newSize.unacknowledgedBytes < 0 || newSize.unacknowledgedCount < 0) { + if (newSize.activeQueueBytes < 0 || newSize.activeQueueCount < 0 || newSize.swappedBytes < 0 || newSize.swappedCount < 0 + || newSize.unacknowledgedBytes < 0 || newSize.unacknowledgedCount < 0) { logger.error("Updated Size of Queue " + counterName + " from " + original + " to " + newSize, new RuntimeException("Cannot create negative queue size"));
