andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

More cleanup

Browse Source
This commit is contained in:
Trustin Lee 2009-03-04 14:11:54 +00:00
parent b9f604ca1d
commit 392900e4b6
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/org/jboss/netty/handler/ssl/SslHandler.java
View File

@ -339,7 +339,8 @@ public class SslHandler extends FrameDecoder {
PendingWrite pendingWrite = PendingWrite pendingWrite =
new PendingWrite(evt.getFuture(), msg.toByteBuffer(msg.readerIndex(), msg.readableBytes())); new PendingWrite(evt.getFuture(), msg.toByteBuffer(msg.readerIndex(), msg.readableBytes()));
synchronized (pendingUnencryptedWrites) { synchronized (pendingUnencryptedWrites) {
pendingUnencryptedWrites.offer(pendingWrite); boolean offered = pendingUnencryptedWrites.offer(pendingWrite);
assert offered;
} }
wrap(context, evt.getChannel()); wrap(context, evt.getChannel());
@ -763,7 +764,8 @@ public class SslHandler extends FrameDecoder {
ChannelFuture closeNotifyFuture = wrapNonAppData(context, e.getChannel()); ChannelFuture closeNotifyFuture = wrapNonAppData(context, e.getChannel());
closeNotifyFuture.addListener(new ChannelFutureListener() { closeNotifyFuture.addListener(new ChannelFutureListener() {
public void operationComplete(ChannelFuture closeNotifyFuture) throws Exception { public void operationComplete(ChannelFuture closeNotifyFuture) throws Exception {
closeFutures.offer(e.getFuture()); boolean offered = closeFutures.offer(e.getFuture());
assert offered;
} }
}); });
} }