aboutsummaryrefslogtreecommitdiff
path: root/bench/websocket-server
diff options
context:
space:
mode:
Diffstat (limited to 'bench/websocket-server')
-rw-r--r--bench/websocket-server/chat-client.mjs15
-rw-r--r--bench/websocket-server/chat-server.bun.js9
-rw-r--r--bench/websocket-server/chat-server.deno.mjs9
-rw-r--r--bench/websocket-server/chat-server.node.mjs8
4 files changed, 12 insertions, 29 deletions
diff --git a/bench/websocket-server/chat-client.mjs b/bench/websocket-server/chat-client.mjs
index 786ebde1c..510c08836 100644
--- a/bench/websocket-server/chat-client.mjs
+++ b/bench/websocket-server/chat-client.mjs
@@ -1,9 +1,4 @@
-const env =
- "process" in globalThis
- ? process.env
- : "Deno" in globalThis
- ? Deno.env.toObject()
- : {};
+const env = "process" in globalThis ? process.env : "Deno" in globalThis ? Deno.env.toObject() : {};
const SERVER = env.SERVER || "ws://0.0.0.0:4001";
const WebSocket = globalThis.WebSocket || (await import("ws")).WebSocket;
@@ -105,10 +100,10 @@ for (let i = 0; i < CLIENTS_TO_WAIT_FOR; i++) {
clients[i] = new WebSocket(`${SERVER}?name=${NAMES[i]}`);
promises.push(
new Promise((resolve, reject) => {
- clients[i].onmessage = (event) => {
+ clients[i].onmessage = event => {
resolve();
};
- })
+ }),
);
}
@@ -121,7 +116,7 @@ var more = false;
var remaining;
for (let i = 0; i < CLIENTS_TO_WAIT_FOR; i++) {
- clients[i].onmessage = (event) => {
+ clients[i].onmessage = event => {
if (LOG_MESSAGES) console.log(event.data);
received++;
remaining--;
@@ -160,7 +155,7 @@ setInterval(() => {
received = 0;
console.log(
last,
- `messages per second (${CLIENTS_TO_WAIT_FOR} clients x ${MESSAGES_TO_SEND.length} msg, min delay: ${DELAY}ms)`
+ `messages per second (${CLIENTS_TO_WAIT_FOR} clients x ${MESSAGES_TO_SEND.length} msg, min delay: ${DELAY}ms)`,
);
if (runs.length >= 10) {
diff --git a/bench/websocket-server/chat-server.bun.js b/bench/websocket-server/chat-server.bun.js
index b015dec7e..b4c71a6dc 100644
--- a/bench/websocket-server/chat-server.bun.js
+++ b/bench/websocket-server/chat-server.bun.js
@@ -38,9 +38,7 @@ const server = Bun.serve({
if (
server.upgrade(req, {
data: {
- name:
- new URL(req.url).searchParams.get("name") ||
- "Client #" + (CLIENTS_TO_WAIT_FOR - remainingClients),
+ name: new URL(req.url).searchParams.get("name") || "Client #" + (CLIENTS_TO_WAIT_FOR - remainingClients),
},
})
)
@@ -50,7 +48,4 @@ const server = Bun.serve({
},
});
-console.log(
- `Waiting for ${remainingClients} clients to connect...\n`,
- ` http://${server.hostname}:${port}/`
-);
+console.log(`Waiting for ${remainingClients} clients to connect...\n`, ` http://${server.hostname}:${port}/`);
diff --git a/bench/websocket-server/chat-server.deno.mjs b/bench/websocket-server/chat-server.deno.mjs
index 3cea9cf2f..5b2130bf2 100644
--- a/bench/websocket-server/chat-server.deno.mjs
+++ b/bench/websocket-server/chat-server.deno.mjs
@@ -1,7 +1,6 @@
// See ./README.md for instructions on how to run this benchmark.
const port = Deno.env.get("PORT") || 4001;
-const CLIENTS_TO_WAIT_FOR =
- parseInt(Deno.env.get("CLIENTS_COUNT") || "", 10) || 16;
+const CLIENTS_TO_WAIT_FOR = parseInt(Deno.env.get("CLIENTS_COUNT") || "", 10) || 16;
var clients = [];
async function reqHandler(req) {
@@ -13,11 +12,9 @@ async function reqHandler(req) {
clients.push(client);
const name = new URL(req.url).searchParams.get("name");
- console.log(
- `${name} connected (${CLIENTS_TO_WAIT_FOR - clients.length} remain)`
- );
+ console.log(`${name} connected (${CLIENTS_TO_WAIT_FOR - clients.length} remain)`);
- client.onmessage = (event) => {
+ client.onmessage = event => {
const msg = `${name}: ${event.data}`;
for (let client of clients) {
client.send(msg);
diff --git a/bench/websocket-server/chat-server.node.mjs b/bench/websocket-server/chat-server.node.mjs
index e57b9b982..5b74e5fbd 100644
--- a/bench/websocket-server/chat-server.node.mjs
+++ b/bench/websocket-server/chat-server.node.mjs
@@ -16,12 +16,8 @@ var WebSocketServer = require("ws").Server,
var clients = [];
wss.on("connection", function (ws, { url }) {
- const name = new URL(new URL(url, "http://localhost:3000")).searchParams.get(
- "name"
- );
- console.log(
- `${name} connected (${CLIENTS_TO_WAIT_FOR - clients.length} remain)`
- );
+ const name = new URL(new URL(url, "http://localhost:3000")).searchParams.get("name");
+ console.log(`${name} connected (${CLIENTS_TO_WAIT_FOR - clients.length} remain)`);
clients.push(ws);
ws.on("message", function (message) {