nifi-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bbe...@apache.org
Subject [6/6] nifi git commit: NIFI-2865: Fixed bug in StreamDemarcator that is exposed when the final bit of data in a stream is smaller than the previous and the previous demarcation ended on a buffer length boundary
Date Thu, 06 Oct 2016 20:12:01 GMT
NIFI-2865: Fixed bug in StreamDemarcator that is exposed when the final bit of data in a stream
is smaller than the previous and the previous demarcation ended on a buffer length boundary

This closes #1110.

Signed-off-by: Bryan Bende <bbende@apache.org>


Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/9304df4d
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/9304df4d
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/9304df4d

Branch: refs/heads/master
Commit: 9304df4de060335526d29a77aa093db4004c8b2e
Parents: b9cb6b1
Author: Mark Payne <markap14@hotmail.com>
Authored: Thu Oct 6 15:39:24 2016 -0400
Committer: Bryan Bende <bbende@apache.org>
Committed: Thu Oct 6 15:51:37 2016 -0400

----------------------------------------------------------------------
 .../main/java/org/apache/nifi/stream/io/util/StreamDemarcator.java  | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/nifi/blob/9304df4d/nifi-commons/nifi-utils/src/main/java/org/apache/nifi/stream/io/util/StreamDemarcator.java
----------------------------------------------------------------------
diff --git a/nifi-commons/nifi-utils/src/main/java/org/apache/nifi/stream/io/util/StreamDemarcator.java
b/nifi-commons/nifi-utils/src/main/java/org/apache/nifi/stream/io/util/StreamDemarcator.java
index dc3d829..840bdb0 100644
--- a/nifi-commons/nifi-utils/src/main/java/org/apache/nifi/stream/io/util/StreamDemarcator.java
+++ b/nifi-commons/nifi-utils/src/main/java/org/apache/nifi/stream/io/util/StreamDemarcator.java
@@ -145,6 +145,7 @@ public class StreamDemarcator implements Closeable {
                 System.arraycopy(this.buffer, this.mark, this.buffer, 0, length);
                 this.index = length;
                 this.mark = 0;
+                this.readAheadLength = length;
             }
         }
 


Mime
View raw message