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

Access control

Browse Source
This commit is contained in:
Trustin Lee 2009-02-09 07:43:34 +00:00
parent 9410fd155e
commit a0e57b4428
3 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/org/jboss/netty/channel/local/LocalChannel.java
View File

@ -55,7 +55,7 @@ public class LocalChannel extends AbstractChannel {
private final LocalChannelConfig config;
final Queue<MessageEvent> writeBuffer = new LinkedTransferQueue<MessageEvent>();
protected LocalChannel(ChannelFactory factory, ChannelPipeline pipeline, ChannelSink sink, LocalChannel pairedChannel) {
LocalChannel(ChannelFactory factory, ChannelPipeline pipeline, ChannelSink sink, LocalChannel pairedChannel) {
super(null, factory, pipeline, sink);
this.pairedChannel = pairedChannel;
config = new LocalChannelConfig();

2
src/main/java/org/jboss/netty/channel/local/LocalServerChannel.java
View File

@ -41,7 +41,7 @@ final class LocalServerChannel extends AbstractServerChannel {
volatile LocalAddress localAddress;
final AtomicBoolean bound = new AtomicBoolean();
protected LocalServerChannel(ChannelFactory factory, ChannelPipeline pipeline, ChannelSink sink) {
LocalServerChannel(ChannelFactory factory, ChannelPipeline pipeline, ChannelSink sink) {
super(factory, pipeline, sink);
channelConfig = new LocalChannelConfig();
fireChannelOpen(this);

4
src/main/java/org/jboss/netty/channel/local/LocalServerChannelSink.java
View File

@ -38,6 +38,10 @@ import org.jboss.netty.channel.MessageEvent;
*/
final class LocalServerChannelSink extends AbstractChannelSink {
LocalServerChannelSink() {
super();
}
public void eventSunk(ChannelPipeline pipeline, ChannelEvent e) throws Exception {
Channel channel = e.getChannel();
if (channel instanceof LocalServerChannel) {