From: Christian Weiske Date: Sun, 21 Jun 2015 04:28:40 +0000 (+0200) Subject: try to handle nightly debug port resets X-Git-Tag: v1.0.0~3 X-Git-Url: https://git.cweiske.de/auerswald-callnotifier.git/commitdiff_plain/bd72383ab1a5742d3ddc102fd3a1b0d4d7d9f2a1?hp=e7dac6ad212a737aec0387d60f84c275c673cdc0 try to handle nightly debug port resets --- diff --git a/src/callnotifier/Exception/ConnectionReset.php b/src/callnotifier/Exception/ConnectionReset.php new file mode 100644 index 0000000..a7bf139 --- /dev/null +++ b/src/callnotifier/Exception/ConnectionReset.php @@ -0,0 +1,11 @@ + \ No newline at end of file diff --git a/src/callnotifier/Source/Remote.php b/src/callnotifier/Source/Remote.php index 39b042c..4145c59 100644 --- a/src/callnotifier/Source/Remote.php +++ b/src/callnotifier/Source/Remote.php @@ -13,9 +13,16 @@ class Source_Remote public function run() { - $this->connect($this->config->host, $this->config->port); - $this->init(); - $this->loop(); + do { + try { + $tryAgain = false; + $this->connect($this->config->host, $this->config->port); + $this->init(); + $this->loop(); + } catch (\Exception_ConnectionReset $e) { + $tryAgain = true; + } + } while ($tryAgain); $this->disconnect(); } @@ -64,6 +71,11 @@ class Source_Remote function read_response() { $res = socket_read($this->socket, 2048, PHP_NORMAL_READ); + if ($res === false) { + //handle "Connection reset by peer" that appears nightly since + // version 4.0N + throw new Exception_ConnectionReset(); + } return substr($res, 2, -1); }