summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorEike Stepper2008-05-26 05:26:28 (EDT)
committerEike Stepper2008-05-26 05:26:28 (EDT)
commitc1aab93f030fd781801c4452f6a24ac97fcc84a7 (patch)
treea422fe069b1c867992c5a680cd98a63c30969c32
parentbef7d41a8456f8885dd1fad53aa7343bc253806f (diff)
downloadcdo-c1aab93f030fd781801c4452f6a24ac97fcc84a7.zip
cdo-c1aab93f030fd781801c4452f6a24ac97fcc84a7.tar.gz
cdo-c1aab93f030fd781801c4452f6a24ac97fcc84a7.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/HTTPClientConnector.java2
-rw-r--r--plugins/org.eclipse.net4j.http/src/org/eclipse/net4j/internal/http/HTTPConnector.java2
2 files changed, 4 insertions, 0 deletions
diff --git a/plugins/org.eclipse.net4j.http/src/org/eclipse/net4j/internal/http/HTTPClientConnector.java b/plugins/org.eclipse.net4j.http/src/org/eclipse/net4j/internal/http/HTTPClientConnector.java
index b89f2d6..d984226 100644
--- a/plugins/org.eclipse.net4j.http/src/org/eclipse/net4j/internal/http/HTTPClientConnector.java
+++ b/plugins/org.eclipse.net4j.http/src/org/eclipse/net4j/internal/http/HTTPClientConnector.java
@@ -225,6 +225,7 @@ public class HTTPClientConnector extends HTTPConnector
private boolean tryBuffersRequest()
{
+ System.out.println("TRYING REQUEST");
synchronized (poller)
{
if (requesting)
@@ -242,6 +243,7 @@ public class HTTPClientConnector extends HTTPConnector
try
{
+ System.out.println("REQUESTING");
final boolean moreBuffers[] = { false };
request(new IOHandler()
{
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 917fe51..d26b776 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
@@ -114,6 +114,7 @@ public abstract class HTTPConnector extends Connector implements IHTTPConnector
IBuffer buffer = queuedBuffer.getBuffer();
short channelIndex = buffer.getChannelIndex();
out.writeShort(channelIndex);
+ System.out.println("WRITING BUFFER");
long channelCount = queuedBuffer.getChannelCount();
out.writeLong(channelCount);
@@ -162,6 +163,7 @@ public abstract class HTTPConnector extends Connector implements IHTTPConnector
}
buffer.flip();
+ System.out.println("READ BUFFER");
handleInputBuffer(channel, bufferCount, buffer);
markLastTraffic();
channelIndex = in.readShort();