From dccd8469ce12caa3371423d990ded002af39b56f Mon Sep 17 00:00:00 2001 From: Josiah Noel <32279667+SentryMan@users.noreply.github.com> Date: Wed, 11 Feb 2026 13:47:58 -0500 Subject: [PATCH] Update UpgradeInputStream.java --- .../share/classes/sun/net/httpserver/ExchangeImpl.java | 2 +- .../share/classes/sun/net/httpserver/UpgradeInputStream.java | 4 +++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/src/jdk.httpserver/share/classes/sun/net/httpserver/ExchangeImpl.java b/src/jdk.httpserver/share/classes/sun/net/httpserver/ExchangeImpl.java index e33a31f5f26..20e9a9aaa93 100644 --- a/src/jdk.httpserver/share/classes/sun/net/httpserver/ExchangeImpl.java +++ b/src/jdk.httpserver/share/classes/sun/net/httpserver/ExchangeImpl.java @@ -281,7 +281,7 @@ class ExchangeImpl { o.setWrappedStream(new UndefLengthOutputStream(this, ros)); close = true; } else if (upgrade && rCode == 101) { - o.setWrappedStream (new UpgradeOutputStream (this, ros)); + o.setWrappedStream (new UpgradeOutputStream(this, ros)); close = true; } else { rspHdrs.set("Transfer-encoding", "chunked"); diff --git a/src/jdk.httpserver/share/classes/sun/net/httpserver/UpgradeInputStream.java b/src/jdk.httpserver/share/classes/sun/net/httpserver/UpgradeInputStream.java index b09d4258865..0394593c8ca 100644 --- a/src/jdk.httpserver/share/classes/sun/net/httpserver/UpgradeInputStream.java +++ b/src/jdk.httpserver/share/classes/sun/net/httpserver/UpgradeInputStream.java @@ -62,7 +62,9 @@ class UpgradeInputStream extends LeftOverInputStream { @Override public void close() throws IOException { closed = true; - t.getServerImpl().requestCompleted(t.getConnection()); + if(t.getConnection().state == State.REQUEST) { + t.getServerImpl().requestCompleted(t.getConnection()); + } } @Override