summaryrefslogtreecommitdiff
path: root/cli/bench/node_tcp_proxy.js
diff options
context:
space:
mode:
authorValentin Anger <syrupthinker@gryphno.de>2020-08-28 15:03:50 +0200
committerGitHub <noreply@github.com>2020-08-28 09:03:50 -0400
commit31f32ed8c4082d36ad2a4ea460366c0d57a5ddbc (patch)
tree2b60111cd53dd4034d1a92ee8caff89d164b7d2d /cli/bench/node_tcp_proxy.js
parent3d23208019a2c9faaf265ff13ad59f2d04f10079 (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.js68
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,
+);