summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorEike Stepper2008-05-26 17:02:36 (EDT)
committerEike Stepper2008-05-26 17:02:36 (EDT)
commitc20f2eb5a813419d58c32869be33567ee1068100 (patch)
treec55a89f5da58b6ff858de6a788df282379181500
parent61066c273ee44e133c2504c07a6b06b50a3b4579 (diff)
downloadcdo-c20f2eb5a813419d58c32869be33567ee1068100.zip
cdo-c20f2eb5a813419d58c32869be33567ee1068100.tar.gz
cdo-c20f2eb5a813419d58c32869be33567ee1068100.tar.bz2
[232648] Provide an HTTPConnector
https://bugs.eclipse.org/bugs/show_bug.cgi?id=232648
-rw-r--r--plugins/org.eclipse.net4j.http/src/org/eclipse/net4j/internal/http/HTTPConnector.java3
-rw-r--r--plugins/org.eclipse.net4j.http/src/org/eclipse/net4j/internal/http/tests/HTTPTest.java2
-rw-r--r--plugins/org.eclipse.net4j/src/org/eclipse/internal/net4j/connector/Connector.java1
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 29b6b0e..c470916 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 3f8ec48..52e5079 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 161f5e3..6a12bf0 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();
}
}