You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@zookeeper.apache.org by si...@apache.org on 2012/09/14 15:42:13 UTC
svn commit: r1384782 [2/2] - in /zookeeper/bookkeeper/trunk: ./
bookkeeper-server/
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/
bookkeeper-server/src/main/java/org/apache/bo...
Modified: zookeeper/bookkeeper/trunk/hedwig-server/src/main/java/org/apache/hedwig/server/topics/ZkHubServerManager.java
URL: http://svn.apache.org/viewvc/zookeeper/bookkeeper/trunk/hedwig-server/src/main/java/org/apache/hedwig/server/topics/ZkHubServerManager.java?rev=1384782&r1=1384781&r2=1384782&view=diff
==============================================================================
--- zookeeper/bookkeeper/trunk/hedwig-server/src/main/java/org/apache/hedwig/server/topics/ZkHubServerManager.java (original)
+++ zookeeper/bookkeeper/trunk/hedwig-server/src/main/java/org/apache/hedwig/server/topics/ZkHubServerManager.java Fri Sep 14 13:42:11 2012
@@ -205,9 +205,7 @@ class ZkHubServerManager implements HubS
@Override
public void uploadSelfLoadData(HubLoad selfLoad) {
- if (logger.isDebugEnabled()) {
- logger.debug("Reporting hub load of {} : {}", myHubInfo, selfLoad);
- }
+ logger.debug("Reporting hub load of {} : {}", myHubInfo, selfLoad);
byte[] loadDataBytes = selfLoad.toString().getBytes();
zk.setData(ephemeralNodePath, loadDataBytes, -1,
loadReportingStatCallback, null);
@@ -267,9 +265,7 @@ class ZkHubServerManager implements HubS
if (rc == KeeperException.Code.OK.intValue()) {
try {
HubLoad load = HubLoad.parse(new String(data));
- if (logger.isDebugEnabled()) {
- logger.debug("Found server " + ctx + " with load: " + load);
- }
+ logger.debug("Found server {} with load: {}", ctx, load);
int compareRes = load.compareTo(minLoad);
if (compareRes < 0 || (compareRes == 0 && rand.nextBoolean())) {
minLoad = load;