blob: 02f5ab944f07b50489d8f573f14867290a2bfb1f (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
// Used for benchmarking Deno's tcp proxy perfromance. See tools/http_benchmark.py
const addr = Deno.args[1] || "127.0.0.1:4500";
const originAddr = Deno.args[2] || "127.0.0.1:4501";
const listener = Deno.listen("tcp", addr);
async function handle(conn: Deno.Conn): Promise<void> {
const origin = await Deno.dial("tcp", originAddr);
try {
await Promise.all([Deno.copy(conn, origin), Deno.copy(origin, conn)]);
} catch (err) {
if (err.message !== "read error" && err.message !== "write error") {
throw err;
}
} finally {
conn.close();
origin.close();
}
}
async function main(): Promise<void> {
console.log(`Proxy listening on http://${addr}/`);
while (true) {
const conn = await listener.accept();
handle(conn);
}
}
main();
|