summaryrefslogtreecommitdiff
path: root/cli/bench/http/deno_http_flash_ops.js
diff options
context:
space:
mode:
Diffstat (limited to 'cli/bench/http/deno_http_flash_ops.js')
-rw-r--r--cli/bench/http/deno_http_flash_ops.js37
1 files changed, 37 insertions, 0 deletions
diff --git a/cli/bench/http/deno_http_flash_ops.js b/cli/bench/http/deno_http_flash_ops.js
new file mode 100644
index 000000000..1b833e7f7
--- /dev/null
+++ b/cli/bench/http/deno_http_flash_ops.js
@@ -0,0 +1,37 @@
+// Copyright 2018-2022 the Deno authors. All rights reserved. MIT license.
+
+// deno-lint-ignore-file
+
+const {
+ core: {
+ opAsync,
+ ops: { op_flash_make_request, op_flash_serve },
+ encode,
+ },
+} = Deno;
+const addr = Deno.args[0] || "127.0.0.1:4500";
+const [hostname, port] = addr.split(":");
+const serverId = op_flash_serve({ hostname, port });
+const serverPromise = opAsync("op_flash_drive_server", serverId);
+
+const fastOps = op_flash_make_request();
+function nextRequest() {
+ return fastOps.nextRequest();
+}
+function respond(token, response) {
+ return fastOps.respond(token, response, true);
+}
+
+const response = encode(
+ "HTTP/1.1 200 OK\r\nContent-Length: 11\r\n\r\nHello World",
+);
+while (true) {
+ let token = nextRequest();
+ if (token === 0) token = await opAsync("op_flash_next_async", serverId);
+ for (let i = 0; i < token; i++) {
+ respond(
+ i,
+ response,
+ );
+ }
+}