diff options
author | Aaron O'Mullan <aaron.omullan@gmail.com> | 2021-09-25 13:22:19 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-09-25 13:22:19 +0200 |
commit | 3c88dffd3262e62f7def6f7437c6ce8a27f6cd73 (patch) | |
tree | 016db98652c42e5df3ce83f7b0627e2e34ef3d97 /cli/tests/unit/http_test.ts | |
parent | 16ea39ee483ec8d256b0361485a7550e158b5fb1 (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.ts | 46 |
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(); + }, +); |