zookeeper-commits mailing list archives

Author: ivank
Date: Wed Feb  8 10:40:19 2012
New Revision: 1241854

URL: http://svn.apache.org/viewvc?rev=1241854&view=rev
Log:
BOOKKEEPER-167: PerChannelBookieClient doesn't use ClientConfiguration (Sijie Guo via ivank)

Modified:
    zookeeper/bookkeeper/trunk/CHANGES.txt
    zookeeper/bookkeeper/trunk/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieClient.java

Modified: zookeeper/bookkeeper/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/zookeeper/bookkeeper/trunk/CHANGES.txt?rev=1241854&r1=1241853&r2=1241854&view=diff
==============================================================================
--- zookeeper/bookkeeper/trunk/CHANGES.txt (original)
+++ zookeeper/bookkeeper/trunk/CHANGES.txt Wed Feb  8 10:40:19 2012
@@ -28,6 +28,8 @@ Trunk (unreleased changes)
 
         BOOKKEEPER-161: PerChannelBookieClient tries to reuse HashedWheelTimer, throws Exception
(ivank)
 
+        BOOKKEEPER-167: PerChannelBookieClient doesn't use ClientConfiguration (Sijie Guo
via ivank)
+
       hedwig-server/
       
         BOOKKEEPER-140: Hub server doesn't subscribe remote region correctly when a region
is down. (Sijie Gou via ivank)

Modified: zookeeper/bookkeeper/trunk/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieClient.java
URL: http://svn.apache.org/viewvc/zookeeper/bookkeeper/trunk/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieClient.java?rev=1241854&r1=1241853&r2=1241854&view=diff
==============================================================================
--- zookeeper/bookkeeper/trunk/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieClient.java
(original)
+++ zookeeper/bookkeeper/trunk/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieClient.java
Wed Feb  8 10:40:19 2012
@@ -65,7 +65,7 @@ public class BookieClient {
         PerChannelBookieClient channel = channels.get(addr);
 
         if (channel == null) {
-            channel = new PerChannelBookieClient(executor, channelFactory, addr, totalBytesOutstanding);
+            channel = new PerChannelBookieClient(conf, executor, channelFactory, addr, totalBytesOutstanding);
             PerChannelBookieClient prevChannel = channels.putIfAbsent(addr, channel);
             if (prevChannel != null) {
                 channel = prevChannel;