43 lines
823 B
D
43 lines
823 B
D
|
/+ dub.sdl:
|
||
|
|
name "tests"
|
||
|
|
description "TCP disconnect task issue"
|
||
|
|
dependency "vibe-core" path="../"
|
||
|
|
versions "VibeDefaultMain"
|
||
|
|
+/
|
||
|
|
module test;
|
||
|
|
|
||
|
|
import vibe.core.core;
|
||
|
|
import vibe.core.net;
|
||
|
|
import core.time : msecs;
|
||
|
|
|
||
|
|
shared static this()
|
||
|
|
{
|
||
|
|
listenTCP(11375,(conn){
|
||
|
|
auto td = runTask!TCPConnection((conn) {
|
||
|
|
ubyte [3] buf;
|
||
|
|
try {
|
||
|
|
conn.read(buf);
|
||
|
|
assert(false, "Expected read() to throw an exception.");
|
||
|
|
} catch (Exception) {} // expected
|
||
|
|
}, conn);
|
||
|
|
sleep(10.msecs);
|
||
|
|
conn.close();
|
||
|
|
});
|
||
|
|
|
||
|
|
runTask({
|
||
|
|
try {
|
||
|
|
auto conn = connectTCP("127.0.0.1", 11375);
|
||
|
|
conn.write("a");
|
||
|
|
conn.close();
|
||
|
|
} catch (Exception e) assert(false, e.msg);
|
||
|
|
|
||
|
|
try {
|
||
|
|
auto conn = connectTCP("127.0.0.1", 11375);
|
||
|
|
conn.close();
|
||
|
|
} catch (Exception e) assert(false, e.msg);
|
||
|
|
|
||
|
|
sleep(50.msecs);
|
||
|
|
exitEventLoop();
|
||
|
|
});
|
||
|
|
}
|