kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jkr...@apache.org
Subject [3/4] git commit: Fix bug in ByteBufferSend that lead to incorrect complete() method.
Date Tue, 11 Feb 2014 04:59:42 GMT
Fix bug in ByteBufferSend that lead to incorrect complete() method.


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/02bb3826
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/02bb3826
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/02bb3826

Branch: refs/heads/trunk
Commit: 02bb382621ea5079ac77094928d12a129db251c0
Parents: d2ec321
Author: Jay Kreps <jay.kreps@gmail.com>
Authored: Sun Feb 9 15:05:04 2014 -0800
Committer: Jay Kreps <jay.kreps@gmail.com>
Committed: Sun Feb 9 15:20:33 2014 -0800

----------------------------------------------------------------------
 .../main/java/org/apache/kafka/common/network/ByteBufferSend.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/02bb3826/clients/src/main/java/org/apache/kafka/common/network/ByteBufferSend.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/common/network/ByteBufferSend.java b/clients/src/main/java/org/apache/kafka/common/network/ByteBufferSend.java
index a8e0413..9305b61 100644
--- a/clients/src/main/java/org/apache/kafka/common/network/ByteBufferSend.java
+++ b/clients/src/main/java/org/apache/kafka/common/network/ByteBufferSend.java
@@ -45,7 +45,7 @@ public class ByteBufferSend implements Send {
 
     @Override
     public boolean complete() {
-        return remaining > 0;
+        return remaining <= 0;
     }
 
     @Override


Mime
View raw message