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

Fix race condition

Browse Source
This commit is contained in:
Daniil Gentili 2021-05-03 23:51:11 +02:00
parent 757f7dbf9e
commit 25267a0ea8
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -250,9 +250,16 @@ class API extends InternalDoc
[$result] = yield from Serialization::tryConnect($this->session->getIpcPath(), $cancel->promise()); [$result] = yield from Serialization::tryConnect($this->session->getIpcPath(), $cancel->promise());
if ($result instanceof ChannelledSocket) { if ($result instanceof ChannelledSocket) {
try { try {
if (!$this->API instanceof Client) {
$this->logger->logger("Restarting to full instance (again): the bot is already running!");
yield $result->disconnect();
return;
}
$API = new Client($result, $this->session, Logger::$default, $this->async); $API = new Client($result, $this->session, Logger::$default, $this->async);
if (yield from $API->hasEventHandler()) { if (yield from $API->hasEventHandler()) {
$this->logger->logger("Restarting to full instance (again): the bot is already running!"); $this->logger->logger("Restarting to full instance (again): the bot is already running!");
yield $API->disconnect();
$API->unreference();
return; return;
} }
$this->logger->logger("Restarting to full instance: stopping another IPC server..."); $this->logger->logger("Restarting to full instance: stopping another IPC server...");
@ -310,6 +317,7 @@ class API extends InternalDoc
// Success, full session // Success, full session
if ($this->API) { if ($this->API) {
$this->API->unreference(); $this->API->unreference();
$this->API = null;
} }
$unserialized->storage = $unserialized->storage ?? []; $unserialized->storage = $unserialized->storage ?? [];
$unserialized->session = $this->session; $unserialized->session = $this->session;