Skip to main content
summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorSimone Bordet2009-09-08 20:04:18 +0000
committerSimone Bordet2009-09-08 20:04:18 +0000
commitdc2a817cd1915c4a2aa670fd4375339e2aadf59b (patch)
tree77087449a899f4cd310e4da9e095372bdc15a1c7
parentcbcbb96be16f3544a3528d12b8c2382299ebc695 (diff)
downloadorg.eclipse.jetty.project-dc2a817cd1915c4a2aa670fd4375339e2aadf59b.tar.gz
org.eclipse.jetty.project-dc2a817cd1915c4a2aa670fd4375339e2aadf59b.tar.xz
org.eclipse.jetty.project-dc2a817cd1915c4a2aa670fd4375339e2aadf59b.zip
Added capability of sending a request without waiting for the response, to test async requests.
git-svn-id: svn+ssh://dev.eclipse.org/svnroot/rt/org.eclipse.jetty/jetty/trunk@832 7e9141cc-0065-0410-87d8-b60c137991c4
-rw-r--r--jetty-server/src/main/java/org/eclipse/jetty/server/LocalConnector.java9
1 files changed, 8 insertions, 1 deletions
diff --git a/jetty-server/src/main/java/org/eclipse/jetty/server/LocalConnector.java b/jetty-server/src/main/java/org/eclipse/jetty/server/LocalConnector.java
index 0d38dcc413..9a577cfd9d 100644
--- a/jetty-server/src/main/java/org/eclipse/jetty/server/LocalConnector.java
+++ b/jetty-server/src/main/java/org/eclipse/jetty/server/LocalConnector.java
@@ -78,6 +78,12 @@ public class LocalConnector extends AbstractConnector
return -1;
}
+ public void executeRequest(String rawRequest) throws IOException
+ {
+ Request request = new Request(new ByteArrayBuffer(rawRequest, "UTF-8"), true, null);
+ requests.add(request);
+ }
+
private class Request implements Runnable
{
private final ByteArrayBuffer requestsBuffer;
@@ -115,7 +121,8 @@ public class LocalConnector extends AbstractConnector
if (!leaveOpen)
connectionClosed(connection);
responsesBuffer = endPoint.getOut();
- latch.countDown();
+ if (latch != null)
+ latch.countDown();
}
}

Back to the top