Skip to content

Allow delayed peer resets in server test #171

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
floitsch merged 2 commits into from
Aug 19, 2026
Merged

Allow delayed peer resets in server test #171

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
a0e0e72
Allow delayed peer resets in server test
floitsch Aug 19, 2026
55926a3
Wait for request before closing test client
floitsch Aug 19, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
13 changes: 9 additions & 4 deletions tests/server-peer-gone-test.toit
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -49,10 +49,12 @@ main:
print "---------------------------------------"
recorder.traces.clear
test --max-tasks=max-tasks --scenario=scenario
traces_seen := recorder.traces.size
allowed := scenario == PROPAGATE ? 1 : 0
if traces_seen != allowed:
failures.add "$scenario/max-tasks=$max-tasks ($traces_seen != $allowed)"
traces-seen := recorder.traces.size
// The OS may report the disconnect during the response write or when
// the server next reads from the connection.
maximum := scenario == PROPAGATE ? 1 : 0
if traces-seen > maximum:
failures.add "$scenario/max-tasks=$max-tasks ($traces-seen > $maximum)"
finally:
recorder.uninstall
expect failures.is-empty --message="$failures"
Expand All @@ -63,12 +65,14 @@ test --max-tasks/int --scenario/string:
port := listen-socket.local-address.port
server := http.Server --max-tasks=max-tasks
client-closed := monitor.Latch
request-received := monitor.Latch
slow-handled := monitor.Latch
done := monitor.Latch

task::
server.listen listen-socket:: | request/http.Request writer/http.ResponseWriter |
if request.path == "/slow":
request-received.set true
try:
client-closed.get // Peer is gone by now.
if scenario == PROPAGATE:
Expand All @@ -86,6 +90,7 @@ test --max-tasks/int --scenario/string:

socket := network.tcp-connect "localhost" port
socket.out.write "GET /slow HTTP/1.1\r\nHost: localhost\r\n\r\n"
with-timeout --ms=5000: request-received.get
socket.close // FIN before the response is written.
client-closed.set true
slow-handled.get
Expand Down