svn commit: r655585 - in /incubator/qpid/trunk/qpid/java: client/src/test/java/org/apache/qpid/test/unit/topic/TopicSessionTest.java common/src/main/java/org/apache/qpidity/transport/network/InputHandler.java

[rhs]

Author: rhs
Date: Mon May 12 11:14:49 2008
New Revision: 655585

URL: http://svn.apache.org/viewvc?rev=655585&view=rev
Log:
QPID-1025: updated fix for empty payload issue, this change removes state 
transitions that don't consume input bytes

Modified:
    
incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/topic/TopicSessionTest.java
    
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/InputHandler.java

Modified: 
incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/topic/TopicSessionTest.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/topic/TopicSessionTest.java?rev=655585&r1=655584&r2=655585&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/topic/TopicSessionTest.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/topic/TopicSessionTest.java
 Mon May 12 11:14:49 2008
@@ -180,7 +180,7 @@
         con.start();
         TextMessage tm = session1.createTextMessage("Hello");
         publisher.publish(tm);
-        tm = (TextMessage) consumer1.receive(200000L);
+        tm = (TextMessage) consumer1.receive(10000L);
         assertNotNull(tm);
         String msgText = tm.getText();
         assertEquals("Hello", msgText);
@@ -188,7 +188,7 @@
         msgText = tm.getText();
         assertNull(msgText);
         publisher.publish(tm);
-        tm = (TextMessage) consumer1.receive(20000000L);
+        tm = (TextMessage) consumer1.receive(10000L);
         assertNotNull(tm);
         msgText = tm.getText();
         assertNull(msgText);

Modified: 
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/InputHandler.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/InputHandler.java?rev=655585&r1=655584&r2=655585&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/InputHandler.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/InputHandler.java
 Mon May 12 11:14:49 2008
@@ -63,9 +63,7 @@
         FRAME_HDR_RSVD3,
         FRAME_HDR_RSVD4,
         FRAME_HDR_RSVD5,
-        FRAME_PAYLOAD,
         FRAME_FRAGMENT,
-        FRAME_END,
         ERROR;
     }
 
@@ -113,7 +111,7 @@
 
     public void received(ByteBuffer buf)
     {
-        while (buf.hasRemaining() || state == FRAME_PAYLOAD)
+        while (buf.hasRemaining())
         {
             state = next(buf);
         }
@@ -188,8 +186,11 @@
         case FRAME_HDR_RSVD4:
             return expect(buf, 0, FRAME_HDR_RSVD5);
         case FRAME_HDR_RSVD5:
-            return expect(buf, 0, FRAME_PAYLOAD);
-        case FRAME_PAYLOAD:
+            if (!expect(buf, 0))
+            {
+                return ERROR;
+            }
+
             frame = new Frame(flags, type, track, channel);
             if (size > buf.remaining()) {
                 frame.addFragment(buf.slice());
@@ -201,7 +202,7 @@
                 buf.position(buf.position() + size);
                 frame.addFragment(payload);
                 frame();
-                return FRAME_END;
+                return FRAME_HDR;
             }
         case FRAME_FRAGMENT:
             int delta = size - frame.getSize();
@@ -215,10 +216,8 @@
                 buf.position(buf.position() + delta);
                 frame.addFragment(fragment);
                 frame();
-                return FRAME_END;
+                return FRAME_HDR;
             }
-        case FRAME_END:
-            return FRAME_HDR;
         default:
             throw new IllegalStateException();
         }
@@ -236,15 +235,35 @@
 
     private State expect(ByteBuffer buf, byte expected, State next)
     {
-        byte b = buf.get();
-        if (b == expected) {
+        if (expect(buf, expected))
+        {
             return next;
-        } else {
-            error("expecting '%x', got '%x'", expected, b);
+        }
+        else
+        {
             return ERROR;
         }
     }
 
+    private boolean expect(ByteBuffer buf, int expected)
+    {
+        return expect(buf, (byte) expected);
+    }
+
+    private boolean expect(ByteBuffer buf, byte expected)
+    {
+        byte b = buf.get();
+        if (b == expected)
+        {
+            return true;
+        }
+        else
+        {
+            error("expecting '%x', got '%x'", expected, b);
+            return false;
+        }
+    }
+
     public void exception(Throwable t)
     {
         receiver.exception(t);