This is an automated email from the ASF dual-hosted git repository.

andor pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/zookeeper.git


The following commit(s) were added to refs/heads/master by this push:
     new 6dc61ad  ZOOKEEPER-3341: Remove Superfluous ByteBuffer Duplicate
6dc61ad is described below

commit 6dc61adbe41c712fbce930e598b3556da54e0667
Author: Beluga Behr <[email protected]>
AuthorDate: Tue Apr 9 16:08:29 2019 +0200

    ZOOKEEPER-3341: Remove Superfluous ByteBuffer Duplicate
    
    Author: Beluga Behr <[email protected]>
    
    Reviewers: [email protected]
    
    Closes #881 from BELUGABEHR/ZOOKEEPER-3341
---
 .../java/org/apache/zookeeper/server/quorum/QuorumCnxManager.java    | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git 
a/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/QuorumCnxManager.java
 
b/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/QuorumCnxManager.java
index 4675333..35f3529 100644
--- 
a/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/QuorumCnxManager.java
+++ 
b/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/QuorumCnxManager.java
@@ -1192,10 +1192,9 @@ public class QuorumCnxManager {
                     /**
                      * Allocates a new ByteBuffer to receive the message
                      */
-                    byte[] msgArray = new byte[length];
+                    final byte[] msgArray = new byte[length];
                     din.readFully(msgArray, 0, length);
-                    ByteBuffer message = ByteBuffer.wrap(msgArray);
-                    addToRecvQueue(new Message(message.duplicate(), sid));
+                    addToRecvQueue(new Message(ByteBuffer.wrap(msgArray), 
sid));
                 }
             } catch (Exception e) {
                 LOG.warn("Connection broken for id " + sid + ", my id = "

Reply via email to