icedream
/
php-language-server
1
0
Fork 0
Code Releases Activity

Exit process if input or output stream is broken

pull/110/head
Kaloyan Raev 2016-10-24 13:28:56 +03:00
parent a19d225a7a
commit 2c1d65db68
2 changed files with 5 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/ProtocolStreamReader.php
View File

@ -29,6 +29,10 @@ class ProtocolStreamReader implements ProtocolReader
{ {
$this->input = $input; $this->input = $input;
Loop\addReadStream($this->input, function() { Loop\addReadStream($this->input, function() {
if (feof($this->input)) {
die;
}
while (($c = fgetc($this->input)) !== false && $c !== '') { while (($c = fgetc($this->input)) !== false && $c !== '') {
$this->buffer .= $c; $this->buffer .= $c;
switch ($this->parsingMode) { switch ($this->parsingMode) {

11
src/ProtocolStreamWriter.php
View File

@ -31,16 +31,7 @@ class ProtocolStreamWriter implements ProtocolWriter
$totalBytesWritten = 0; $totalBytesWritten = 0;
while ($totalBytesWritten < $msgSize) { while ($totalBytesWritten < $msgSize) {
error_clear_last(); $bytesWritten = fwrite($this->output, substr($data, $totalBytesWritten));
$bytesWritten = @fwrite($this->output, substr($data, $totalBytesWritten));
if ($bytesWritten === false) {
$error = error_get_last();
if ($error !== null) {
throw new RuntimeException('Could not write message: ' . error_get_last()['message']);
} else {
throw new RuntimeException('Could not write message');
}
}
$totalBytesWritten += $bytesWritten; $totalBytesWritten += $bytesWritten;
} }
} }