diff options
3 files changed, 4 insertions, 2 deletions
diff --git a/plugins/org.eclipse.net4j.http/src/org/eclipse/net4j/internal/http/HTTPConnector.java b/plugins/org.eclipse.net4j.http/src/org/eclipse/net4j/internal/http/HTTPConnector.java index 29b6b0eea2..c470916e2a 100644 --- a/plugins/org.eclipse.net4j.http/src/org/eclipse/net4j/internal/http/HTTPConnector.java +++ b/plugins/org.eclipse.net4j.http/src/org/eclipse/net4j/internal/http/HTTPConnector.java @@ -455,8 +455,7 @@ public abstract class HTTPConnector extends Connector implements IHTTPConnector @Override public void doEexecute(HTTPChannel channel) { - System.out.println("OPERATION_CLOSE"); - throw new UnsupportedOperationException(); + inverseRemoveChannel(channel.getChannelID(), channel.getChannelIndex()); } } diff --git a/plugins/org.eclipse.net4j.http/src/org/eclipse/net4j/internal/http/tests/HTTPTest.java b/plugins/org.eclipse.net4j.http/src/org/eclipse/net4j/internal/http/tests/HTTPTest.java index 3f8ec48e6a..52e5079626 100644 --- a/plugins/org.eclipse.net4j.http/src/org/eclipse/net4j/internal/http/tests/HTTPTest.java +++ b/plugins/org.eclipse.net4j.http/src/org/eclipse/net4j/internal/http/tests/HTTPTest.java @@ -122,6 +122,8 @@ public class HTTPTest extends AbstractTransportTest assertEquals(305419896, result); sleep(500); + channel.close(); + sleep(500); connector.deactivate(); } diff --git a/plugins/org.eclipse.net4j/src/org/eclipse/internal/net4j/connector/Connector.java b/plugins/org.eclipse.net4j/src/org/eclipse/internal/net4j/connector/Connector.java index 161f5e35d2..6a12bf0767 100644 --- a/plugins/org.eclipse.net4j/src/org/eclipse/internal/net4j/connector/Connector.java +++ b/plugins/org.eclipse.net4j/src/org/eclipse/internal/net4j/connector/Connector.java @@ -572,6 +572,7 @@ public abstract class Connector extends Container<IChannel> implements IConnecto if (removed) { + channel.removeListener(channelListener); channel.close(); } } |