Improved changes introduced by a746d78.

jetty-client/src/main/java/org/eclipse/jetty/client/HttpSender.java

@@ -776,7 +776,6 @@ public abstract class HttpSender implements AsyncContentProvider.Listener
         public void onCompleteFailure(Throwable failure)
         {
             content.failed(failure);
-            super.failed(failure);
             anyToFailure(failure);
         }
 

jetty-fcgi/fcgi-client/src/main/java/org/eclipse/jetty/fcgi/generator/Flusher.java

@@ -111,8 +111,6 @@ public class Flusher
                     break;
                 result.failed(x);
             }
-
-            super.failed(x);
         }
     }
 

jetty-spdy/spdy-core/src/main/java/org/eclipse/jetty/spdy/Flusher.java

@@ -261,7 +261,6 @@ public class Flusher
             // Notify outside the synchronized block.
             for (StandardSession.FrameBytes frame : failed)
                 frame.failed(x);
-            super.failed(x);
         }
     }
 }

jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/extensions/ExtensionStack.java

@@ -394,7 +394,9 @@ public class ExtensionStack extends ContainerLifeCycle implements IncomingFrames
         @Override
         protected void onCompleteFailure(Throwable x)
         {
-            // TODO This IteratingCallback never completes???
+            // This IteratingCallback never fails.
+            // The callback are those provided by WriteCallback (implemented
+            // below) and even in case of writeFailed() we call succeeded().
         }
         
         @Override

jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/extensions/compress/CompressExtension.java

@@ -376,7 +376,10 @@ public abstract class CompressExtension extends AbstractExtension
         @Override
         protected void onCompleteFailure(Throwable x)
         {
-            // TODO This IteratingCallback never completes???
+            // Fail all the frames in the queue.
+            FrameEntry entry;
+            while ((entry = entries.poll()) != null)
+                notifyCallbackFailure(entry.callback, x);
         }
 
         @Override
@@ -394,10 +397,6 @@ public abstract class CompressExtension extends AbstractExtension
             // If something went wrong, very likely the compression context
             // will be invalid, so we need to fail this IteratingCallback.
             failed(x);
-            // Now no more frames can be queued, fail those in the queue.
-            FrameEntry entry;
-            while ((entry = entries.poll()) != null)
-                notifyCallbackFailure(entry.callback, x);
         }
     }
 }

jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/extensions/fragment/FragmentExtension.java

@@ -158,7 +158,9 @@ public class FragmentExtension extends AbstractExtension
         @Override
         protected void onCompleteFailure(Throwable x)
         {
-            // TODO This IteratingCallback never completes???
+            // This IteratingCallback never fails.
+            // The callback are those provided by WriteCallback (implemented
+            // below) and even in case of writeFailed() we call succeeded().
         }
         
         @Override

jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/io/FrameFlusher.java

@@ -105,7 +105,6 @@ public class FrameFlusher
                 entry.release();
             }
             entries.clear();
-            super.failed(x);
             failure = x;
             onFailure(x);
         }