From 52f3af0758b1a2e9f0cae49a2002abf53839dc95 Mon Sep 17 00:00:00 2001 From: Radek Davidek Date: Wed, 4 Mar 2026 14:34:10 +0100 Subject: [PATCH] fix --- .../cz/kamma/xtreamplayer/XtreamPlayerApplication.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/src/main/java/cz/kamma/xtreamplayer/XtreamPlayerApplication.java b/src/main/java/cz/kamma/xtreamplayer/XtreamPlayerApplication.java index bc6ad70..c7367e7 100644 --- a/src/main/java/cz/kamma/xtreamplayer/XtreamPlayerApplication.java +++ b/src/main/java/cz/kamma/xtreamplayer/XtreamPlayerApplication.java @@ -283,6 +283,11 @@ public final class XtreamPlayerApplication { break; } } catch (Exception candidateException) { + if (candidateException instanceof InterruptedException) { + Thread.currentThread().interrupt(); + writeJson(exchange, 500, errorJson("Stream proxy interrupted.")); + return; + } attemptErrors.add(maskUri(candidate) + " -> " + compactError(candidateException)); LOGGER.warn("Stream proxy candidate failed uri={}", maskUri(candidate), candidateException); } @@ -317,9 +322,6 @@ public final class XtreamPlayerApplication { copyResponseHeaderIfPresent(response, exchange, "Expires"); exchange.getResponseHeaders().set("Content-Type", contentType); writeBytes(exchange, response.statusCode(), body, contentType); - } catch (InterruptedException interruptedException) { - Thread.currentThread().interrupt(); - writeJson(exchange, 500, errorJson("Stream proxy interrupted.")); } catch (Exception exception) { LOGGER.error("Stream proxy failed for {}", maskUri(target), exception); writeJson(exchange, 502, errorJson("Unable to proxy stream: " + exception.getMessage()));