danog/MadelineProto
1
0
Fork 0
mirror of https://github.com/danog/MadelineProto.git synced 2025-01-23 00:11:20 +01:00
Code Issues Projects Releases Wiki Activity

Abort if the lock cannot be acquired

Browse Source
This commit is contained in:
Daniil Gentili 2021-07-01 15:43:00 +02:00
parent e298dbc6b4
commit eaa5e30bf1
Signed by: danog
GPG Key ID: 8C1BE3B34B230CA7
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/danog/MadelineProto/API.php
View File

@ -288,7 +288,7 @@ class API extends InternalDoc
*
* @return \Generator
*/
protected function connectToMadelineProto(SettingsAbstract $settings, bool $forceFull = false): \Generator
protected function connectToMadelineProto(SettingsAbstract $settings, bool $forceFull = false, bool $tryReconnect = true): \Generator
{
if ($settings instanceof SettingsIpc) {
$forceFull = $forceFull || $settings->getSlow();
@ -306,9 +306,12 @@ class API extends InternalDoc
if ($unserialized === 0) {
// Timeout
Logger::log("!!! Could not connect to MadelineProto, please check and report the logs for more details. !!!", Logger::FATAL_ERROR);
if (!$tryReconnect) {
throw new Exception('Could not connect to MadelineProto, please check the MadelineProto.log file to debug!');
}
Logger::log("!!! Reconnecting using slower method. !!!", Logger::FATAL_ERROR);
// IPC server error, try fetching full session
return yield from $this->connectToMadelineProto($settings, true);
return yield from $this->connectToMadelineProto($settings, true, false);
} elseif ($unserialized instanceof \Throwable) {
// IPC server error, try fetching full session
return yield from $this->connectToMadelineProto($settings, true);