svn commit: r1392270 - in /cxf/trunk/rt/transports: http-jetty/src/main/java/org/apache/cxf/transport/http_jetty/continuations/JettyContinuationWrapper.java http/src/main/java/org/apache/cxf/transport/http/Servlet3ContinuationProvider.java

[sergeyb]

Author: sergeyb
Date: Mon Oct  1 10:39:28 2012
New Revision: 1392270

URL: http://svn.apache.org/viewvc?rev=1392270&view=rev
Log:
Resetting isPending status when the continuation is resumed

Modified:
    
cxf/trunk/rt/transports/http-jetty/src/main/java/org/apache/cxf/transport/http_jetty/continuations/JettyContinuationWrapper.java
    
cxf/trunk/rt/transports/http/src/main/java/org/apache/cxf/transport/http/Servlet3ContinuationProvider.java

Modified: 
cxf/trunk/rt/transports/http-jetty/src/main/java/org/apache/cxf/transport/http_jetty/continuations/JettyContinuationWrapper.java
URL: 
http://svn.apache.org/viewvc/cxf/trunk/rt/transports/http-jetty/src/main/java/org/apache/cxf/transport/http_jetty/continuations/JettyContinuationWrapper.java?rev=1392270&r1=1392269&r2=1392270&view=diff
==============================================================================
--- 
cxf/trunk/rt/transports/http-jetty/src/main/java/org/apache/cxf/transport/http_jetty/continuations/JettyContinuationWrapper.java
 (original)
+++ 
cxf/trunk/rt/transports/http-jetty/src/main/java/org/apache/cxf/transport/http_jetty/continuations/JettyContinuationWrapper.java
 Mon Oct  1 10:39:28 2012
@@ -60,6 +60,7 @@ public class JettyContinuationWrapper im
 
     public void resume() {
         isResumed = true;
+        isPending = false;
         continuation.resume();
     }
 
@@ -106,10 +107,12 @@ public class JettyContinuationWrapper im
     public void onComplete(org.eclipse.jetty.continuation.Continuation cont) {
         getMessage().remove(AbstractHTTPDestination.CXF_CONTINUATION_MESSAGE);
         isPending = false;
+        //REVISIT: isResumed = false;
     }
 
     public void onTimeout(org.eclipse.jetty.continuation.Continuation cont) {
         isPending = false;
+        //isResumed = true;
     }
     
 }

Modified: 
cxf/trunk/rt/transports/http/src/main/java/org/apache/cxf/transport/http/Servlet3ContinuationProvider.java
URL: 
http://svn.apache.org/viewvc/cxf/trunk/rt/transports/http/src/main/java/org/apache/cxf/transport/http/Servlet3ContinuationProvider.java?rev=1392270&r1=1392269&r2=1392270&view=diff
==============================================================================
--- 
cxf/trunk/rt/transports/http/src/main/java/org/apache/cxf/transport/http/Servlet3ContinuationProvider.java
 (original)
+++ 
cxf/trunk/rt/transports/http/src/main/java/org/apache/cxf/transport/http/Servlet3ContinuationProvider.java
 Mon Oct  1 10:39:28 2012
@@ -99,6 +99,7 @@ public class Servlet3ContinuationProvide
         }
         public void resume() {
             isResumed = true;
+            isPending = false;
             redispatch();
         }
 
@@ -131,6 +132,7 @@ public class Servlet3ContinuationProvide
             inMessage.getExchange().getInMessage()
                 .remove(AbstractHTTPDestination.CXF_CONTINUATION_MESSAGE);
             isPending = false;
+            //REVISIT: isResumed = false;
         }
         public void onError(AsyncEvent event) throws IOException {
         }
@@ -138,6 +140,7 @@ public class Servlet3ContinuationProvide
         }
         public void onTimeout(AsyncEvent event) throws IOException {
             isPending = false;
+            //REVISIT: isResumed = true;
             redispatch();
         }