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

Removed the usage of Channels.messageEvent() which is obsolete

Browse Source
This commit is contained in:
Trustin Lee 2009-02-11 09:52:36 +00:00
parent 2030411759
commit 73cb446310
1 changed files with 19 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -24,6 +24,7 @@ package org.jboss.netty.handler.ssl;
import static org.jboss.netty.channel.Channels.*; import static org.jboss.netty.channel.Channels.*;
import java.net.SocketAddress;
import java.nio.ByteBuffer; import java.nio.ByteBuffer;
import java.nio.channels.ClosedChannelException; import java.nio.channels.ClosedChannelException;
import java.util.LinkedList; import java.util.LinkedList;
@ -47,6 +48,7 @@ import org.jboss.netty.channel.ChannelHandlerContext;
import org.jboss.netty.channel.ChannelPipeline; import org.jboss.netty.channel.ChannelPipeline;
import org.jboss.netty.channel.ChannelStateEvent; import org.jboss.netty.channel.ChannelStateEvent;
import org.jboss.netty.channel.Channels; import org.jboss.netty.channel.Channels;
import org.jboss.netty.channel.DownstreamMessageEvent;
import org.jboss.netty.channel.MessageEvent; import org.jboss.netty.channel.MessageEvent;
import org.jboss.netty.handler.codec.frame.FrameDecoder; import org.jboss.netty.handler.codec.frame.FrameDecoder;
import org.jboss.netty.logging.InternalLogger; import org.jboss.netty.logging.InternalLogger;
@ -461,7 +463,8 @@ public class SslHandler extends FrameDecoder {
future = pendingWrite.future; future = pendingWrite.future;
} }
MessageEvent encryptedWrite = messageEvent(channel, future, msg); MessageEvent encryptedWrite = new DownstreamMessageEvent(
channel, future, msg, channel.getRemoteAddress());
if (Thread.holdsLock(pendingEncryptedWrites)) { if (Thread.holdsLock(pendingEncryptedWrites)) {
pendingEncryptedWrites.offer(encryptedWrite); pendingEncryptedWrites.offer(encryptedWrite);
} else { } else {
@ -788,4 +791,19 @@ public class SslHandler extends FrameDecoder {
this.outAppBuf = outAppBuf; this.outAppBuf = outAppBuf;
} }
} }
private static final class EncryptedMessageEvent extends DownstreamMessageEvent {
/**
* @param channel
* @param future
* @param message
* @param remoteAddress
*/
public EncryptedMessageEvent(Channel channel, ChannelFuture future,
Object message, SocketAddress remoteAddress) {
super(channel, future, message, remoteAddress);
}
}
} }