diff options
author | Valentin Anger <syrupthinker@gryphno.de> | 2020-08-28 15:03:50 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-08-28 09:03:50 -0400 |
commit | 31f32ed8c4082d36ad2a4ea460366c0d57a5ddbc (patch) | |
tree | 2b60111cd53dd4034d1a92ee8caff89d164b7d2d /cli/bench/node_tcp_proxy.js | |
parent | 3d23208019a2c9faaf265ff13ad59f2d04f10079 (diff) |
Move benchmarks to Rust (#7134)
All benchmarks are done in Rust and can be invoked with
`cargo bench`.
Currently this has it's own "harness" that behaves like
`./tools/benchmark.py` did.
Because of this tests inside `cli/bench` are currently not run.
This should be switched to the language provided harness
once the `#[bench]` attribute has been stabilized.
Diffstat (limited to 'cli/bench/node_tcp_proxy.js')
-rw-r--r-- | cli/bench/node_tcp_proxy.js | 68 |
1 files changed, 68 insertions, 0 deletions
diff --git a/cli/bench/node_tcp_proxy.js b/cli/bench/node_tcp_proxy.js new file mode 100644 index 000000000..d693dc5c8 --- /dev/null +++ b/cli/bench/node_tcp_proxy.js @@ -0,0 +1,68 @@ +const net = require("net"); + +process.on("uncaughtException", function (error) { + console.error(error); +}); + +if (process.argv.length != 4) { + console.log("usage: %s <localport> <remoteport>", process.argv[1]); + process.exit(); +} + +const localport = process.argv[2]; +const remoteport = process.argv[3]; + +const remotehost = "127.0.0.1"; + +const server = net.createServer(function (localsocket) { + const remotesocket = new net.Socket(); + + remotesocket.connect(remoteport, remotehost); + + localsocket.on("data", function (data) { + const flushed = remotesocket.write(data); + if (!flushed) { + localsocket.pause(); + } + }); + + remotesocket.on("data", function (data) { + const flushed = localsocket.write(data); + if (!flushed) { + remotesocket.pause(); + } + }); + + localsocket.on("drain", function () { + remotesocket.resume(); + }); + + remotesocket.on("drain", function () { + localsocket.resume(); + }); + + localsocket.on("close", function () { + remotesocket.end(); + }); + + remotesocket.on("close", function () { + localsocket.end(); + }); + + localsocket.on("error", function () { + localsocket.end(); + }); + + remotesocket.on("error", function () { + remotesocket.end(); + }); +}); + +server.listen(localport); + +console.log( + "redirecting connections from 127.0.0.1:%d to %s:%d", + localport, + remotehost, + remoteport, +); |