You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by tk...@apache.org on 2015/03/26 04:13:47 UTC
incubator-nifi git commit: NIFI-464 This closes #45 (minor revision -
replace hard coded constant with length)
Repository: incubator-nifi
Updated Branches:
refs/heads/develop a5e140f10 -> 3a27c378c
NIFI-464 This closes #45 (minor revision - replace hard coded constant
with length)
Project: http://git-wip-us.apache.org/repos/asf/incubator-nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-nifi/commit/3a27c378
Tree: http://git-wip-us.apache.org/repos/asf/incubator-nifi/tree/3a27c378
Diff: http://git-wip-us.apache.org/repos/asf/incubator-nifi/diff/3a27c378
Branch: refs/heads/develop
Commit: 3a27c378cc143abc5e59dfb746c5e0d09341b185
Parents: a5e140f
Author: Tony Kurc <tr...@gmail.com>
Authored: Wed Mar 25 21:52:23 2015 -0400
Committer: Tony Kurc <tr...@gmail.com>
Committed: Wed Mar 25 23:10:36 2015 -0400
----------------------------------------------------------------------
.../apache/nifi/distributed/cache/protocol/ProtocolHandshake.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/3a27c378/nifi/nifi-nar-bundles/nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-protocol/src/main/java/org/apache/nifi/distributed/cache/protocol/ProtocolHandshake.java
----------------------------------------------------------------------
diff --git a/nifi/nifi-nar-bundles/nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-protocol/src/main/java/org/apache/nifi/distributed/cache/protocol/ProtocolHandshake.java b/nifi/nifi-nar-bundles/nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-protocol/src/main/java/org/apache/nifi/distributed/cache/protocol/ProtocolHandshake.java
index da2acad..55cf51f 100644
--- a/nifi/nifi-nar-bundles/nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-protocol/src/main/java/org/apache/nifi/distributed/cache/protocol/ProtocolHandshake.java
+++ b/nifi/nifi-nar-bundles/nifi-standard-services/nifi-distributed-cache-services-bundle/nifi-distributed-cache-protocol/src/main/java/org/apache/nifi/distributed/cache/protocol/ProtocolHandshake.java
@@ -53,7 +53,7 @@ public class ProtocolHandshake {
final DataOutputStream dos = new DataOutputStream(out);
try {
- final byte[] magicHeaderBuffer = new byte[4];
+ final byte[] magicHeaderBuffer = new byte[MAGIC_HEADER.length];
dis.readFully(magicHeaderBuffer);
receiveVersionNegotiation(versionNegotiator, dis, dos);