summaryrefslogtreecommitdiff
path: root/cli/tests/unit/http_test.ts
diff options
context:
space:
mode:
authorAaron O'Mullan <aaron.omullan@gmail.com>2021-09-25 13:22:19 +0200
committerGitHub <noreply@github.com>2021-09-25 13:22:19 +0200
commit3c88dffd3262e62f7def6f7437c6ce8a27f6cd73 (patch)
tree016db98652c42e5df3ce83f7b0627e2e34ef3d97 /cli/tests/unit/http_test.ts
parent16ea39ee483ec8d256b0361485a7550e158b5fb1 (diff)
fix(http): panic when responding to a closed conn (#12216)
Our oneshot receiver in `HyperService::call` would unwrap and panic, the `.await` on the oneshot receiver happens when the sender is dropped. The sender is dropped in `op_http_response` because: 1. We take `ResponseSenderResource` 2. Then get `ConnResource` and early exit on failure (conn already closed) 3. The taken sender then gets dropped in this early exit before any response is sent over the channel Fallbacking to returning a dummy response to hyper seems to be a fine quickfix
Diffstat (limited to 'cli/tests/unit/http_test.ts')
-rw-r--r--cli/tests/unit/http_test.ts46
1 files changed, 46 insertions, 0 deletions
diff --git a/cli/tests/unit/http_test.ts b/cli/tests/unit/http_test.ts
index f93d28efa..2dc08cfa1 100644
--- a/cli/tests/unit/http_test.ts
+++ b/cli/tests/unit/http_test.ts
@@ -936,3 +936,49 @@ unitTest(
await promise;
},
);
+
+// https://github.com/denoland/deno/pull/12216
+unitTest(
+ { permissions: { net: true } },
+ async function droppedConnSenderNoPanic() {
+ async function server(listener: Deno.Listener) {
+ const conn = await listener.accept();
+ const http = Deno.serveHttp(conn);
+
+ for (;;) {
+ const req = await http.nextRequest();
+ if (req == null) break;
+
+ nextloop()
+ .then(() => {
+ http.close();
+ return req.respondWith(new Response("boom"));
+ })
+ .catch(() => {});
+ }
+
+ try {
+ http.close();
+ } catch {
+ "nop";
+ }
+
+ listener.close();
+ }
+
+ async function client() {
+ const resp = await fetch("http://127.0.0.1:8000/");
+ await resp.body?.cancel();
+ }
+
+ function nextloop() {
+ return new Promise((resolve) => setTimeout(resolve, 0));
+ }
+
+ async function main() {
+ const listener = Deno.listen({ port: 8000 });
+ await Promise.all([server(listener), client()]);
+ }
+ await main();
+ },
+);