bdware/router-backend
2
0
Fork 0
mirror of https://gitee.com/BDWare/router-backend synced 2025-01-26 09:44:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

update files

Browse Source
This commit is contained in:
CaiHQ 2022-05-26 15:57:05 +08:00
parent 09dd8618d9
commit 39fe0e22f3
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/org/bdware/server/nodecenter/FileActions.java
View File

@ -53,9 +53,8 @@ public class FileActions {
method = org.bdware.server.http.HttpMethod.POST, method = org.bdware.server.http.HttpMethod.POST,
value = {"/upload"}) value = {"/upload"})
public static void handleUploadRequest(ChannelHandlerContext ctx, FullHttpRequest request) { public static void handleUploadRequest(ChannelHandlerContext ctx, FullHttpRequest request) {
// logger.info("[CMHttpHandler] handleUploadRequest : "); LOGGER.info("[FileActions] handleUploadRequest : ");
// Upload method is POST // Upload method is POST
QueryStringDecoder decoderQuery = new QueryStringDecoder(request.uri()); QueryStringDecoder decoderQuery = new QueryStringDecoder(request.uri());
Map<String, List<String>> params = decoderQuery.parameters(); Map<String, List<String>> params = decoderQuery.parameters();
Map<String, String> transformedParam = new HashMap<>(); Map<String, String> transformedParam = new HashMap<>();

7
src/main/java/org/bdware/server/nodecenter/NCHttpHandler.java
View File

@ -86,7 +86,8 @@ public class NCHttpHandler extends SimpleChannelInboundHandler<HttpObject> {
return flag && flag2; return flag && flag2;
} }
}; };
static TypeToken<Map<String, String>> token = new TypeToken<Map<String, String>>() {}; static TypeToken<Map<String, String>> token = new TypeToken<Map<String, String>>() {
};
private final HttpFileHandleAdapter fileAdapter; private final HttpFileHandleAdapter fileAdapter;
// public static ExecutorService executor = Executors.newFixedThreadPool(5); // public static ExecutorService executor = Executors.newFixedThreadPool(5);
public AtomicInteger counter = new AtomicInteger(0); public AtomicInteger counter = new AtomicInteger(0);
@ -196,8 +197,8 @@ public class NCHttpHandler extends SimpleChannelInboundHandler<HttpObject> {
@Override @Override
public void channelRead0(ChannelHandlerContext ctx, HttpObject msg) { public void channelRead0(ChannelHandlerContext ctx, HttpObject msg) {
// logger.debug("[NCHttpHandler] TID:" + Thread.currentThread().getId() + LOGGER.debug("[NCHttpHandler] TID:" + Thread.currentThread().getId() +
// msg.toString()); msg.toString());
if (msg instanceof FullHttpRequest) { if (msg instanceof FullHttpRequest) {
FullHttpRequest request = (FullHttpRequest) msg; FullHttpRequest request = (FullHttpRequest) msg;
handler.handle(ctx, request); handler.handle(ctx, request);