From c633d1c0e8f8b749bea1fcb9865dbad2819e184c Mon Sep 17 00:00:00 2001 From: redkale Date: Thu, 18 Jan 2024 15:08:49 +0800 Subject: [PATCH] youhua --- src/main/java/org/redkale/net/Response.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/src/main/java/org/redkale/net/Response.java b/src/main/java/org/redkale/net/Response.java index 107549c2f..63e91a0be 100644 --- a/src/main/java/org/redkale/net/Response.java +++ b/src/main/java/org/redkale/net/Response.java @@ -196,16 +196,16 @@ public abstract class Response> { @SuppressWarnings("unchecked") public void nextEvent() throws IOException { if (this.filter != null) { - Filter runner = this.filter; + Filter f = this.filter; this.filter = this.filter._next; if (inNonBlocking) { - if (runner.isNonBlocking()) { - runner.doFilter(request, this); + if (f.isNonBlocking()) { + f.doFilter(request, this); } else { inNonBlocking = false; workExecutor.execute(() -> { try { - runner.doFilter(request, Response.this); + f.doFilter(request, Response.this); } catch (Throwable t) { context.getLogger().log(Level.WARNING, "Filter occur exception. request = " + request, t); finishError(t); @@ -213,7 +213,7 @@ public abstract class Response> { }); } } else { - runner.doFilter(request, this); + f.doFilter(request, this); } return; } @@ -397,7 +397,7 @@ public abstract class Response> { } } - public void finish(boolean kill, final byte[] bs1, int offset1, int length1, final byte[] bs2, int offset2, int length2) { + public void finish(boolean kill, final byte[] bs1, int offset1, int length1, final byte[] bs2, int offset2, int length2) { if (kill) { refuseAlive(); }