lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

youhua

Browse Source
This commit is contained in:
redkale
2024-01-18 15:08:49 +08:00
parent e347a43738
commit c633d1c0e8
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/java/org/redkale/net/Response.java
View File

@@ -196,16 +196,16 @@ public abstract class Response<C extends Context, R extends Request<C>> {
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
public void nextEvent() throws IOException { public void nextEvent() throws IOException {
if (this.filter != null) { if (this.filter != null) {
Filter runner = this.filter; Filter f = this.filter;
this.filter = this.filter._next; this.filter = this.filter._next;
if (inNonBlocking) { if (inNonBlocking) {
if (runner.isNonBlocking()) { if (f.isNonBlocking()) {
runner.doFilter(request, this); f.doFilter(request, this);
} else { } else {
inNonBlocking = false; inNonBlocking = false;
workExecutor.execute(() -> { workExecutor.execute(() -> {
try { try {
runner.doFilter(request, Response.this); f.doFilter(request, Response.this);
} catch (Throwable t) { } catch (Throwable t) {
context.getLogger().log(Level.WARNING, "Filter occur exception. request = " + request, t); context.getLogger().log(Level.WARNING, "Filter occur exception. request = " + request, t);
finishError(t); finishError(t);
@@ -213,7 +213,7 @@ public abstract class Response<C extends Context, R extends Request<C>> {
}); });
} }
} else { } else {
runner.doFilter(request, this); f.doFilter(request, this);
} }
return; return;
} }
@@ -397,7 +397,7 @@ public abstract class Response<C extends Context, R extends Request<C>> {
} }
} }
public <A> 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) { if (kill) {
refuseAlive(); refuseAlive();
} }