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

Browse Source
This commit is contained in:
Redkale
2018-05-30 18:45:01 +08:00
parent 6bb2e152a5
commit d5409518ed
1 changed files with 5 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
src/org/redkale/net/PrepareRunner.java
View File

@@ -61,15 +61,9 @@ public final class PrepareRunner implements Runnable {
@Override @Override
public void completed(Integer count, Void attachment1) { public void completed(Integer count, Void attachment1) {
if (count < 1) { if (count < 1) {
try { response.request.offerReadBuffer(buffer);
response.request.offerReadBuffer(buffer); response.finish(true);
response.finish(true); channel.dispose();// response.init(channel); 在调用之前异常
channel.close();// response.init(channel); 在调用之前异常
} catch (Exception e) {
if (context.logger.isLoggable(Level.FINEST)) {
context.logger.log(Level.FINEST, "PrepareRunner close channel erroneous on no read bytes", e);
}
}
return; return;
} }
// { //测试 // { //测试
@@ -92,10 +86,7 @@ public final class PrepareRunner implements Runnable {
public void failed(Throwable exc, Void attachment2) { public void failed(Throwable exc, Void attachment2) {
response.request.offerReadBuffer(buffer); response.request.offerReadBuffer(buffer);
response.finish(true); response.finish(true);
try { // response.init(channel); 可能在调用之前异常 channel.dispose(); // response.init(channel); 可能在调用之前异常
channel.close();
} catch (Exception e) {
}
if (exc != null && context.logger.isLoggable(Level.FINEST)) { if (exc != null && context.logger.isLoggable(Level.FINEST)) {
context.logger.log(Level.FINEST, "Servlet Handler read channel erroneous, forece to close channel ", exc); context.logger.log(Level.FINEST, "Servlet Handler read channel erroneous, forece to close channel ", exc);
} }
@@ -104,10 +95,7 @@ public final class PrepareRunner implements Runnable {
} catch (Exception te) { } catch (Exception te) {
response.request.offerReadBuffer(buffer); response.request.offerReadBuffer(buffer);
response.finish(true); response.finish(true);
try { // response.init(channel); 可能在调用之前异常 channel.dispose(); // response.init(channel); 可能在调用之前异常
channel.close();
} catch (Exception e) {
}
if (te != null && context.logger.isLoggable(Level.FINEST)) { if (te != null && context.logger.isLoggable(Level.FINEST)) {
context.logger.log(Level.FINEST, "Servlet read channel erroneous, forece to close channel ", te); context.logger.log(Level.FINEST, "Servlet read channel erroneous, forece to close channel ", te);
} }