Adding trace for delivering a message

belaban · Aug 21, 2012 · 2f6400d · 2f6400d
1 parent 6ed3da9
commit 2f6400d
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/src/org/jgroups/protocols/pbcast/NAKACK.java b/src/org/jgroups/protocols/pbcast/NAKACK.java
@@ -702,8 +702,11 @@ private void handleMessage(Message msg, NakAckHeader hdr) {
             if(loopback)
                 msg=win.get(hdr.seqno); // we *have* to get a message, because loopback means we didn't add it to win !
             if(msg != null && msg.isFlagSet(Message.OOB)) {
-                if(msg.setTransientFlagIfAbsent(Message.OOB_DELIVERED))
+                if(msg.setTransientFlagIfAbsent(Message.OOB_DELIVERED)) {
+                    if(log.isTraceEnabled())
+                        log.trace(new StringBuilder().append(local_addr).append(": delivering ").append(sender).append('#').append(hdr.seqno));
                     up_prot.up(new Event(Event.MSG, msg));
+                }
             }
         }
 
@@ -736,6 +739,10 @@ private void handleMessage(Message msg, NakAckHeader hdr) {
 
                     //msg_to_deliver.removeHeader(getName()); // Changed by bela Jan 29 2003: not needed (see above)
                     try {
+                        if(log.isTraceEnabled()) {
+                            NakAckHeader header=(NakAckHeader)msg_to_deliver.getHeader(this.id);
+                            log.trace(new StringBuilder().append(local_addr).append(": delivering ").append(sender).append('#').append(header.seqno));
+                        }
                         up_prot.up(new Event(Event.MSG, msg_to_deliver));
                     }
                     catch(Throwable t) {