debian-packages/vibe-core
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Avoid socket leaks in examples.

Browse source
This commit is contained in:
Sönke Ludwig 2020-11-25 23:23:58 +01:00
parent 958856f6f1
commit a44d3f2655
2 changed files with 9 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
examples/bench-dummy-http-server/source/app.d
View file

@ -19,7 +19,7 @@ void main()
conn.readLine(r);
if (!r.count) break;
}
conn.write(cast(const(ubyte)[])"HTTP/1.1 200 OK\r\nContent-Length: 13\r\nContent-Type: text/plain\r\nConnection: keep-alive\r\n\r\nHello, World!");
conn.write(cast(const(ubyte)[])"HTTP/1.1 200 OK\r\nContent-Length: 13\r\nContent-Type: text/plain\r\nConnection: keep-alive\r\nKeep-Alive: timeout=10\r\n\r\nHello, World!");
conn.flush();
}
} catch (Exception e) {
@ -30,6 +30,7 @@ void main()
auto listener = listenTCP(8080, &staticAnswer, "127.0.0.1");
logInfo("Listening to HTTP requests on http://127.0.0.1:8080/");
scope (exit) listener.stopListening();
runApplication();
}

8
examples/echo-server/source/app.d
View file

@ -5,10 +5,16 @@ import vibe.core.stream : pipe;
void main()
{
listenTCP(7000, (conn) @safe nothrow {
auto listeners = listenTCP(7000, (conn) @safe nothrow {
try pipe(conn, conn);
catch (Exception e)
logError("Error: %s", e.msg);
});
// closes the listening sockets
scope (exit)
foreach (l; listeners)
l.stopListening();
runApplication();
}