actix/examples
1
0
Fork 0
mirror of https://github.com/actix/examples synced 2025-06-26 09:17:41 +02:00
Code Issues Releases Wiki Activity

chore: fmt

Browse Source
This commit is contained in:
Rob Ede
2024-08-07 02:04:57 +01:00
parent b7b1005d2a
commit f30795f014
16 changed files with 100 additions and 89 deletions
Download Patch File Download Diff File Expand all files Collapse all files

52
server-sent-events/benchmark.js
View File

@ -1,73 +1,73 @@
const http = require('http')
const http = require("http")
const n = 120
let connected = 0
let messages = 0
let start = Date.now()
let phase = 'connecting'
let phase = "connecting"
let connection_time
let broadcast_time
let message = process.argv[2] || 'msg'
let expected_data = 'data: ' + message
let message = process.argv[2] || "msg"
let expected_data = "data: " + message
for (let i = 0; i < n; i++) {
http
.get(
{
host: '127.0.0.1',
host: "127.0.0.1",
port: 8080,
path: '/events',
path: "/events",
},
(response) => {
response.on('data', (data) => {
response => {
response.on("data", data => {
if (data.includes(expected_data)) {
messages += 1
} else if (data.includes('data: connected\n')) {
} else if (data.includes("data: connected\n")) {
connected += 1
}
})
}
},
)
.on('error', (_) => {})
.on("error", _ => {})
}
setInterval(() => {
if (phase === 'connecting' && connected === n) {
if (phase === "connecting" && connected === n) {
// done connecting
phase = 'messaging'
phase = "messaging"
connection_time = Date.now() - start
}
if (phase === 'messaging') {
phase = 'waiting'
if (phase === "messaging") {
phase = "waiting"
start = Date.now()
http
.request(
{
method: 'POST',
host: '127.0.0.1',
method: "POST",
host: "127.0.0.1",
port: 8080,
path: '/broadcast/' + message,
path: "/broadcast/" + message,
},
response => {
response.on("data", _ => {})
},
(response) => {
response.on('data', (_) => {})
}
)
.end()
}
if (phase === 'waiting' && messages >= n) {
if (phase === "waiting" && messages >= n) {
// all messages received
broadcast_time = Date.now() - start
phase = 'paused'
phase = "paused"
messages = 0
phase = 'messaging'
phase = "messaging"
}
process.stdout.write('\r\x1b[K')
process.stdout.write("\r\x1b[K")
process.stdout.write(
`Connected: ${connected}, connection time: ${connection_time} ms, total broadcast time: ${broadcast_time} ms`
`Connected: ${connected}, connection time: ${connection_time} ms, total broadcast time: ${broadcast_time} ms`,
)
}, 20)

25
server-sent-events/drain.js
View File

@ -1,41 +1,42 @@
const http = require('http')
const http = require("http")
let drop_goal = 5_000
let dropped = 0
let query = {
method: 'POST',
host: '127.0.0.1',
method: "POST",
host: "127.0.0.1",
port: 8080,
path: '/events',
path: "/events",
}
setInterval(() => {
if (dropped < drop_goal) {
let request = http
.request(query, (response) => {
response.on('data', (data) => {
if (data.includes('data: connected\n')) {
.request(query, response => {
response.on("data", data => {
if (data.includes("data: connected\n")) {
// drop connection after welcome message
dropped += 1
request.abort()
}
})
})
.on('error', () => {})
.on("error", () => {})
.end()
}
}, 0)
setInterval(() => {
http.request({ ...query, path: '/' }, () => print_status(true))
http
.request({ ...query, path: "/" }, () => print_status(true))
.setTimeout(100, () => print_status(false))
.on('error', () => {})
.on("error", () => {})
}, 20)
function print_status(accepting_connections) {
process.stdout.write('\r\x1b[K')
process.stdout.write("\r\x1b[K")
process.stdout.write(
`Connections dropped: ${dropped}, accepting connections: ${accepting_connections}`
`Connections dropped: ${dropped}, accepting connections: ${accepting_connections}`,
)
}