|
@@ -323,7 +323,6 @@ public class LearnerHandler extends ZooKeeperThread {
|
|
* @throws InterruptedException
|
|
* @throws InterruptedException
|
|
*/
|
|
*/
|
|
private void sendPackets() throws InterruptedException {
|
|
private void sendPackets() throws InterruptedException {
|
|
- long traceMask = ZooTrace.SERVER_PACKET_TRACE_MASK;
|
|
|
|
while (true) {
|
|
while (true) {
|
|
try {
|
|
try {
|
|
QuorumPacket p;
|
|
QuorumPacket p;
|
|
@@ -347,13 +346,15 @@ public class LearnerHandler extends ZooKeeperThread {
|
|
// Packet of death!
|
|
// Packet of death!
|
|
break;
|
|
break;
|
|
}
|
|
}
|
|
- if (p.getType() == Leader.PING) {
|
|
|
|
- traceMask = ZooTrace.SERVER_PING_TRACE_MASK;
|
|
|
|
- }
|
|
|
|
|
|
+
|
|
if (p.getType() == Leader.PROPOSAL) {
|
|
if (p.getType() == Leader.PROPOSAL) {
|
|
syncLimitCheck.updateProposal(p.getZxid(), System.nanoTime());
|
|
syncLimitCheck.updateProposal(p.getZxid(), System.nanoTime());
|
|
}
|
|
}
|
|
if (LOG.isTraceEnabled()) {
|
|
if (LOG.isTraceEnabled()) {
|
|
|
|
+ long traceMask = ZooTrace.SERVER_PACKET_TRACE_MASK;
|
|
|
|
+ if (p.getType() == Leader.PING) {
|
|
|
|
+ traceMask = ZooTrace.SERVER_PING_TRACE_MASK;
|
|
|
|
+ }
|
|
ZooTrace.logQuorumPacket(LOG, traceMask, 'o', p);
|
|
ZooTrace.logQuorumPacket(LOG, traceMask, 'o', p);
|
|
}
|
|
}
|
|
|
|
|
|
@@ -652,11 +653,11 @@ public class LearnerHandler extends ZooKeeperThread {
|
|
ia.readRecord(qp, "packet");
|
|
ia.readRecord(qp, "packet");
|
|
messageTracker.trackReceived(qp.getType());
|
|
messageTracker.trackReceived(qp.getType());
|
|
|
|
|
|
- long traceMask = ZooTrace.SERVER_PACKET_TRACE_MASK;
|
|
|
|
- if (qp.getType() == Leader.PING) {
|
|
|
|
- traceMask = ZooTrace.SERVER_PING_TRACE_MASK;
|
|
|
|
- }
|
|
|
|
if (LOG.isTraceEnabled()) {
|
|
if (LOG.isTraceEnabled()) {
|
|
|
|
+ long traceMask = ZooTrace.SERVER_PACKET_TRACE_MASK;
|
|
|
|
+ if (qp.getType() == Leader.PING) {
|
|
|
|
+ traceMask = ZooTrace.SERVER_PING_TRACE_MASK;
|
|
|
|
+ }
|
|
ZooTrace.logQuorumPacket(LOG, traceMask, 'i', qp);
|
|
ZooTrace.logQuorumPacket(LOG, traceMask, 'i', qp);
|
|
}
|
|
}
|
|
tickOfNextAckDeadline = learnerMaster.getTickOfNextAckDeadline();
|
|
tickOfNextAckDeadline = learnerMaster.getTickOfNextAckDeadline();
|