Bugfixes
This commit is contained in:
parent
69c1663194
commit
54040e14a1
2
docs
2
docs
@ -1 +1 @@
|
||||
Subproject commit 4ed3a8447cf21c69322bcdaf149eb3ce0befe8c0
|
||||
Subproject commit dfec70a8c5a6a6eca9e9d47e582141bc8a86aba8
|
@ -118,7 +118,7 @@ class CheckLoop extends ResumableSignalLoop
|
||||
break;
|
||||
case 4:
|
||||
if ($chr & 32) {
|
||||
if ($connection->new_outgoing[$message_id]['sent'] + $timeoutResend < \time()) {
|
||||
if ($connection->outgoing_messages[$message_id]['sent'] + $timeoutResend < \time()) {
|
||||
$API->logger->logger('Message '.$connection->outgoing_messages[$message_id]['_'].' with message ID '.($message_id).' received by server and is being processed for way too long, resending request...', \danog\MadelineProto\Logger::ERROR);
|
||||
$connection->methodRecall('', ['message_id' => $message_id, 'postpone' => true]);
|
||||
} else {
|
||||
|
@ -392,7 +392,7 @@ trait ResponseHandler
|
||||
|
||||
return;
|
||||
}
|
||||
if (\in_array($response['error_message'], ['MSGID_DECREASE_RETRY', 'RPC_CALL_FAIL', 'PERSISTENT_TIMESTAMP_OUTDATED', 'RPC_MCGET_FAIL', 'no workers running'])) {
|
||||
if (\in_array($response['error_message'], ['MSGID_DECREASE_RETRY', 'RPC_CALL_FAIL', 'PERSISTENT_TIMESTAMP_OUTDATED', 'RPC_MCGET_FAIL', 'no workers running', 'No workers running'])) {
|
||||
Loop::delay(1 * 1000, [$this, 'methodRecall'], ['message_id' => $request_id, ]);
|
||||
return;
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user