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

Fixed a problem where LocalChannel.getParent() always returns null

Browse Source
This commit is contained in:
Trustin Lee 2009-02-09 07:46:45 +00:00
parent a0e57b4428
commit ce7ca53bdf
3 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

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

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

@ -39,7 +39,7 @@ public class LocalClientChannelFactory implements ChannelFactory {
}
public Channel newChannel(ChannelPipeline pipeline) {
return new LocalChannel(this, pipeline, sink, null);
return new LocalChannel(null, this, pipeline, sink, null);
}
public void releaseExternalResources() {

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

@ -129,7 +129,7 @@ final class LocalClientChannelSink extends AbstractChannelSink {
}
future.setSuccess();
LocalChannel acceptedChannel = new LocalChannel(serverChannel.getFactory(), pipeline, this, channel);
LocalChannel acceptedChannel = new LocalChannel(serverChannel, serverChannel.getFactory(), pipeline, this, channel);
channel.pairedChannel = acceptedChannel;
bind(channel, succeededFuture(channel), LocalAddress.newEphemeralInstance());