svn commit: r665733 - in /incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport: Channel.java Method.java Session.java SessionDelegate.java

[rhs]

Author: rhs
Date: Mon Jun  9 09:07:17 2008
New Revision: 665733

URL: http://svn.apache.org/viewvc?rev=665733&view=rev
Log:
QPID-901: added logging of sync bit and command-id

Modified:
    
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/Channel.java
    
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/Method.java
    
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/Session.java
    
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/SessionDelegate.java

Modified: 
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/Channel.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/Channel.java?rev=665733&r1=665732&r2=665733&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/Channel.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/Channel.java
 Mon Jun  9 09:07:17 2008
@@ -212,4 +212,9 @@
         throw new UnsupportedOperationException();
     }
 
+    public String toString()
+    {
+        return String.format("%s:%s", connection, channel);
+    }
+
 }

Modified: 
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/Method.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/Method.java?rev=665733&r1=665732&r2=665733&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/Method.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/Method.java
 Mon Jun  9 09:07:17 2008
@@ -40,6 +40,7 @@
 
     // XXX: command subclass?
     private int id;
+    private boolean idSet = false;
     private boolean sync = false;
 
     public final int getId()
@@ -50,6 +51,7 @@
     void setId(int id)
     {
         this.id = id;
+        this.idSet = true;
     }
 
     public final boolean isSync()
@@ -80,4 +82,36 @@
         }
     }
 
+    public String toString()
+    {
+        if (getEncodedTrack() != Frame.L4)
+        {
+            return super.toString();
+        }
+
+        StringBuilder str = new StringBuilder();
+
+        if (idSet)
+        {
+            str.append("id=");
+            str.append(id);
+        }
+
+        if (sync)
+        {
+            if (str.length() > 0)
+            {
+                str.append(" ");
+            }
+            str.append(" [sync]");
+        }
+
+        if (str.length() > 0)
+        {
+            str.append(" ");
+        }
+        str.append(super.toString());
+        return str.toString();
+    }
+
 }

Modified: 
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/Session.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/Session.java?rev=665733&r1=665732&r2=665733&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/Session.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/Session.java
 Mon Jun  9 09:07:17 2008
@@ -123,6 +123,12 @@
         return commandsIn++;
     }
 
+    void identify(Method cmd)
+    {
+        cmd.setId(nextCommandId());
+        log.debug("ID: [%s] %s", this.channel, cmd);
+    }
+
     public void processed(Method command)
     {
         processed(command.getId());
@@ -155,7 +161,7 @@
         }
     }
 
-   public void flushProcessed()
+    public void flushProcessed()
     {
         RangeSet copy;
         synchronized (processedLock)
@@ -244,6 +250,7 @@
             synchronized (commands)
             {
                 int next = commandsOut++;
+                m.setId(next);
                 if (next == 0)
                 {
                     sessionCommandPoint(0, 0);
@@ -357,7 +364,9 @@
                 }
                 else
                 {
-                    throw new RuntimeException("timed out waiting for sync");
+                    throw new RuntimeException
+                        (String.format
+                         ("timed out waiting for sync: complete = %s, point = 
%s", maxComplete, point));
                 }
             }
         }

Modified: 
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/SessionDelegate.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/SessionDelegate.java?rev=665733&r1=665732&r2=665733&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/SessionDelegate.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/SessionDelegate.java
 Mon Jun  9 09:07:17 2008
@@ -40,7 +40,7 @@
     }
 
     public void command(Session ssn, Method method) {
-        method.setId(ssn.nextCommandId());
+        ssn.identify(method);
         method.dispatch(ssn, this);
         if (!method.hasPayload())
         {