Repository: zookeeper
Updated Branches:
refs/heads/branch-3.4 d6bbfd76d -> f0ef24a5e
ZOOKEEPER-2622: ZooTrace.logQuorumPacket does nothing
Author: fpj <fpj@apache.org>
Reviewers: Edward Ribeiro <edward.ribeiro@gmail.com>
Closes #95 from fpj/ZK-2622
(cherry picked from commit edf75b5e31f0d9e2fbfadbd95bae9d1d6c4737f6)
Signed-off-by: arshad <arshad@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/zookeeper/repo
Commit: http://git-wip-us.apache.org/repos/asf/zookeeper/commit/f0ef24a5
Tree: http://git-wip-us.apache.org/repos/asf/zookeeper/tree/f0ef24a5
Diff: http://git-wip-us.apache.org/repos/asf/zookeeper/diff/f0ef24a5
Branch: refs/heads/branch-3.4
Commit: f0ef24a5e5df110ae569c1d3085e3cea8b454d9c
Parents: d6bbfd7
Author: Flavio Junqueira <fpj@apache.org>
Authored: Sat Jan 28 11:13:53 2017 +0530
Committer: arshad <arshad@apache.org>
Committed: Sat Jan 28 11:19:16 2017 +0530
----------------------------------------------------------------------
src/java/main/org/apache/zookeeper/server/ZooTrace.java | 12 +++++-------
1 file changed, 5 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/zookeeper/blob/f0ef24a5/src/java/main/org/apache/zookeeper/server/ZooTrace.java
----------------------------------------------------------------------
diff --git a/src/java/main/org/apache/zookeeper/server/ZooTrace.java b/src/java/main/org/apache/zookeeper/server/ZooTrace.java
index ac14fe2..946a4bf 100644
--- a/src/java/main/org/apache/zookeeper/server/ZooTrace.java
+++ b/src/java/main/org/apache/zookeeper/server/ZooTrace.java
@@ -20,7 +20,7 @@ package org.apache.zookeeper.server;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-
+import org.apache.zookeeper.server.quorum.LearnerHandler;
import org.apache.zookeeper.server.quorum.QuorumPacket;
/**
@@ -75,12 +75,10 @@ public class ZooTrace {
static public void logQuorumPacket(Logger log, long mask,
char direction, QuorumPacket qp)
{
- return;
-
- // if (isTraceEnabled(log, mask)) {
- // logTraceMessage(LOG, mask, direction + " "
- // + FollowerHandler.packetToString(qp));
- // }
+ if (isTraceEnabled(log, mask)) {
+ logTraceMessage(log, mask, direction +
+ " " + LearnerHandler.packetToString(qp));
+ }
}
static public void logRequest(Logger log, long mask,
|