You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by bb...@apache.org on 2015/11/06 15:10:17 UTC
nifi git commit: Fixing check-style violation in StandardFlowFileQueue
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 <bb...@apache.org>
Authored: Fri Nov 6 09:10:10 2015 -0500
Committer: Bryan Bende <bb...@apache.org>
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"));