Serialize onCompleteFailure for #9059

jetty · Dec 16, 2022 · 4be6ac3 · 4be6ac3
1 parent 0ada3d4
commit 4be6ac3
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/jetty-util/src/main/java/org/eclipse/jetty/util/IteratingCallback.java b/jetty-util/src/main/java/org/eclipse/jetty/util/IteratingCallback.java
@@ -296,12 +296,12 @@ private void processing()
                     }
 
                     case FAILED:
+                    case CLOSED:
                         onCompleteFailure = _failure;
                         _failure = null;
                         break processing;
 
                     case SUCCEEDED:
-                    case CLOSED:
                         break processing;
 
                     case IDLE:
@@ -410,6 +410,11 @@ public void close()
                     _state = State.CLOSED;
                     break;
 
+                case PENDING:
+                    _failure = new IOException(String.format("Close %s in state %s", this, _state));
+                    _state = State.CLOSED;
+                    break;
+
                 case CLOSED:
                     break;