danog/dns
1
0
Fork 0
mirror of https://github.com/danog/dns.git synced 2024-11-26 20:14:51 +01:00
Code Issues Projects Releases Wiki Activity

Unload server when fwrite fails

Browse Source 
Ignore errors from fwrite caused by disconnected sockets and immediately unload the server.
This commit is contained in:
Aaron Piotrowski 2017-03-02 16:38:11 -06:00
parent 5fc1cde2d2
commit 4e4d6e9f81
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
lib/DefaultResolver.php
View File

@ -195,11 +195,11 @@ REGEX;
} }
// Send request // Send request
$bytesWritten = \fwrite($server->socket, $requestPacket); $bytesWritten = @\fwrite($server->socket, $requestPacket);
if ($bytesWritten === false || isset($packet[$bytesWritten])) { if ($bytesWritten === false || $bytesWritten === 0 && (!\is_resource($server->socket) || !\feof($server->socket))) {
throw new ResolutionException( $exception = new ResolutionException("Request send failed");
"Request send failed" $this->unloadServer($server->id, $exception);
); throw $exception;
} }
$promisor = new Deferred; $promisor = new Deferred;
@ -265,6 +265,7 @@ REGEX;
$uri = $this->parseCustomServerUri($options["server"]); $uri = $this->parseCustomServerUri($options["server"]);
} }
$promises = [];
foreach ($types as $type) { foreach ($types as $type) {
$promises[] = $this->doRequest($uri, $name, $type); $promises[] = $this->doRequest($uri, $name, $type);
} }