summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorEike Stepper2008-05-26 10:10:16 (EDT)
committerEike Stepper2008-05-26 10:10:16 (EDT)
commitabddeef026ede357e99c46a4596c541828f1ecf3 (patch)
tree7f809dce894c77f39819ca6f70d72302bb1c00b5
parented41612d6f45c9a65070a384ec02fd0d47f07737 (diff)
downloadcdo-abddeef026ede357e99c46a4596c541828f1ecf3.zip
cdo-abddeef026ede357e99c46a4596c541828f1ecf3.tar.gz
cdo-abddeef026ede357e99c46a4596c541828f1ecf3.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.java20
1 files changed, 14 insertions, 6 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 f7ad662..6e62149 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
@@ -145,9 +145,15 @@ public abstract class HTTPConnector extends Connector implements IHTTPConnector
{
case OPERATION_OPEN:
operation = new OpenChannelOperation(in);
+ break;
+
+ case OPERATION_OPEN_ACK:
+ operation = new OpenAckChannelOperation(in);
+ break;
case OPERATION_CLOSE:
operation = new CloseChannelOperation(in);
+ break;
case OPERATION_BUFFER:
operation = new BufferChannelOperation(in);
@@ -346,6 +352,13 @@ public abstract class HTTPConnector extends Connector implements IHTTPConnector
}
@Override
+ public void write(ExtendedDataOutputStream out) throws IOException
+ {
+ super.write(out);
+ out.writeBoolean(success);
+ }
+
+ @Override
public byte getOperation()
{
return OPERATION_OPEN_ACK;
@@ -376,12 +389,6 @@ public abstract class HTTPConnector extends Connector implements IHTTPConnector
}
@Override
- public void write(ExtendedDataOutputStream out) throws IOException
- {
- super.write(out);
- }
-
- @Override
public byte getOperation()
{
return OPERATION_CLOSE;
@@ -390,6 +397,7 @@ public abstract class HTTPConnector extends Connector implements IHTTPConnector
@Override
public void execute()
{
+ System.out.println("OPERATION_CLOSE");
throw new UnsupportedOperationException();
}
}