danog/MadelineProto
2
2
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Bugfix

Browse Source
This commit is contained in:
Daniil Gentili 2019-06-25 18:02:56 +02:00
parent 949bd194ed
commit 214fc0d0f9
1 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/danog/MadelineProto/Loop/Connection/ReadLoop.php
View File

@ -18,6 +18,8 @@
namespace danog\MadelineProto\Loop\Connection; namespace danog\MadelineProto\Loop\Connection;
use Amp\ByteStream\PendingReadError;
use Amp\ByteStream\StreamException;
use Amp\Loop; use Amp\Loop;
use Amp\Websocket\ClosedException; use Amp\Websocket\ClosedException;
use danog\MadelineProto\Logger; use danog\MadelineProto\Logger;
@ -25,7 +27,6 @@ use danog\MadelineProto\Loop\Impl\SignalLoop;
use danog\MadelineProto\MTProtoTools\Crypt; use danog\MadelineProto\MTProtoTools\Crypt;
use danog\MadelineProto\NothingInTheSocketException; use danog\MadelineProto\NothingInTheSocketException;
use danog\MadelineProto\Tools; use danog\MadelineProto\Tools;
use Amp\ByteStream\StreamException;
/** /**
* Socket read loop. * Socket read loop.
@ -57,7 +58,7 @@ class ReadLoop extends SignalLoop
while (true) { while (true) {
try { try {
$error = yield $this->waitSignal($this->readMessage()); $error = yield $this->waitSignal($this->readMessage());
} catch (NothingInTheSocketException|StreamException $e) { } catch (NothingInTheSocketException | StreamException | PendingReadError $e) {
if (isset($connection->old)) { if (isset($connection->old)) {
return; return;
} }
@ -65,10 +66,6 @@ class ReadLoop extends SignalLoop
$API->logger->logger("Got nothing in the socket in DC {$datacenter}, reconnecting...", Logger::ERROR); $API->logger->logger("Got nothing in the socket in DC {$datacenter}, reconnecting...", Logger::ERROR);
yield $connection->reconnect(); yield $connection->reconnect();
continue; continue;
} catch (ClosedException $e) {
$API->logger->logger($e->getMessage(), Logger::FATAL_ERROR);
throw $e;
} }
if (is_int($error)) { if (is_int($error)) {