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

优化

Browse Source
This commit is contained in:
redkale
2024-09-04 22:54:18 +08:00
parent cfcb11ae61
commit ec7f54809f
4 changed files with 6 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -214,7 +214,7 @@ public abstract class Response<C extends Context, R extends Request<C>> {
inNonBlocking = false; inNonBlocking = false;
workExecutor.execute(() -> { workExecutor.execute(() -> {
try { try {
f.doFilter(request, Response.this); f.doFilter(request, 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);
@@ -236,7 +236,7 @@ public abstract class Response<C extends Context, R extends Request<C>> {
inNonBlocking = false; inNonBlocking = false;
workExecutor.execute(() -> { workExecutor.execute(() -> {
try { try {
s.execute(request, Response.this); s.execute(request, this);
} catch (Throwable t) { } catch (Throwable t) {
context.getLogger().log(Level.WARNING, "Servlet occur exception. request = " + request, t); context.getLogger().log(Level.WARNING, "Servlet occur exception. request = " + request, t);
finishError(t); finishError(t);

2
src/main/java/org/redkale/net/http/HttpRequest.java
View File

@@ -1247,7 +1247,7 @@ public class HttpRequest extends Request<HttpContext> {
} }
@Override @Override
protected Serializable getRequestid() { protected final Serializable getRequestid() {
return null; return null;
} }

2
src/main/java/org/redkale/net/http/HttpResponse.java
View File

@@ -858,7 +858,7 @@ public class HttpResponse extends Response<HttpContext, HttpRequest> {
} else if (val instanceof CompletionStage) { } else if (val instanceof CompletionStage) {
finishFuture(convert, val == obj ? type : null, (CompletionStage) val); finishFuture(convert, val == obj ? type : null, (CompletionStage) val);
} else if (val instanceof CharSequence) { } else if (val instanceof CharSequence) {
finish((String) val.toString()); finish(val.toString());
} else if (val instanceof byte[]) { } else if (val instanceof byte[]) {
finish((byte[]) val); finish((byte[]) val);
} else if (val instanceof File) { } else if (val instanceof File) {

5
src/main/java/org/redkale/net/sncp/SncpRequest.java
View File

@@ -5,8 +5,6 @@
*/ */
package org.redkale.net.sncp; package org.redkale.net.sncp;
import static org.redkale.net.client.ClientRequest.EMPTY_TRACEID;
import java.io.Serializable; import java.io.Serializable;
import java.nio.ByteBuffer; import java.nio.ByteBuffer;
import java.nio.charset.StandardCharsets; import java.nio.charset.StandardCharsets;
@@ -15,6 +13,7 @@ import java.util.logging.Level;
import org.redkale.convert.*; import org.redkale.convert.*;
import org.redkale.convert.bson.BsonReader; import org.redkale.convert.bson.BsonReader;
import org.redkale.net.Request; import org.redkale.net.Request;
import static org.redkale.net.client.ClientRequest.EMPTY_TRACEID;
import org.redkale.util.*; import org.redkale.util.*;
/** /**
@@ -159,7 +158,7 @@ public class SncpRequest extends Request<SncpContext> {
} }
@Override @Override
protected Serializable getRequestid() { protected final Serializable getRequestid() {
return header.getSeqid(); return header.getSeqid();
} }