danog/byte-stream
1
0
Fork 0
mirror of https://github.com/danog/byte-stream.git synced 2024-11-30 04:19:23 +01:00
Code Issues Projects Releases Wiki Activity

Add closed stream test with leaked FDs

Browse Source
This commit is contained in:
Niklas Keller 2018-04-03 18:30:21 +02:00
parent 56e814943a
commit 43a93e6240
1 changed files with 32 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
test/ResourceOutputStreamTest.php
View File

@ -60,4 +60,36 @@ class ResourceOutputStreamTest extends TestCase {
wait($stream->write("foobar"));
wait($stream->write("foobar"));
}
public function testClosedRemoteSocketWithFork() {
$server = \stream_socket_server("tcp://127.0.0.1:0");
$address = \stream_socket_get_name($server, false);
$a = \stream_socket_client("tcp://" . $address);
$b = \stream_socket_accept($server);
// Creates a fork without having to deal with it…
// The fork inherits the FDs of the current process.
$proc = \proc_open("sleep 3", [
['pipe', 'r'],
['pipe', 'w'],
['pipe', 'w'],
], $pipes);
$stream = new ResourceOutputStream($a);
\stream_socket_shutdown($b, \STREAM_SHUT_RDWR);
\fclose($b);
$this->expectException(StreamException::class);
$this->expectExceptionMessage("Failed to write to stream; fwrite():");
try {
// The first write still succeeds somehow...
wait($stream->write("foobar"));
wait($stream->write("foobar"));
} finally {
\proc_terminate($proc);
\proc_close($proc);
}
}
}