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

readRegister

Browse Source
This commit is contained in:
redkale
2024-10-15 00:26:05 +08:00
parent 3e06534b63
commit 0d45e6c43b
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -114,7 +114,9 @@ class ProtocolCodec implements CompletionHandler<Integer, ByteBuffer> {
return; return;
} }
try { try {
channel.readRegisterInIOThread(this); // channel.readRegisterInIOThread(this);
// 服务端接收到一个SocketConnection后调用，因此不存在并发readRegister
channel.readRegister(this);
} catch (Exception te) { } catch (Exception te) {
channel.dispose(); // response.init(channel); 在调用之前异常 channel.dispose(); // response.init(channel); 在调用之前异常
if (context.logger.isLoggable(Level.FINEST)) { if (context.logger.isLoggable(Level.FINEST)) {