Appwrite/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite.git synced 2026-05-26 13:51:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

add rounds to connection attempts and adjust attempts sleep between rounds

Browse Source
This commit is contained in:
shimon
2023-08-31 11:44:54 +03:00
parent aced75fd05
commit 806ac22aa7
1 changed files with 40 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/http.php
+40 -17
View File
@@ -66,24 +66,47 @@ $http->on('start', function (Server $http) use ($payloadSize, $register) {
App::setResource('pools', fn () => $pools);
// wait for database to be ready
$attempts = 0;
$max = 10;
$sleep = 1;
do {
try {
$attempts++;
$dbForConsole = $app->getResource('dbForConsole');
/** @var Utopia\Database\Database $dbForConsole */
break; // leave the do-while if successful
} catch (\Exception $e) {
Console::warning("Database not ready. Retrying connection ({$attempts})...");
if ($attempts >= $max) {
throw new \Exception('Failed to connect to database: ' . $e->getMessage());
}
sleep($sleep);
$rounds = 0;
$max = 10; //max attempts per round
$sleep = 1; // initial sleep value
$maxRounds = 2; // max round
$delay = 5; // delay each round
$sleepInc = 5; // Increment sleep after each round
$leave = false; // exit rounds loop
while (true) {
if ($leave === true) {
break;
}
} while ($attempts < $max);
$attempts = 0;
do {
try {
$attempts++;
if ($attempts === $max) {
$sleep = + $sleepInc;
}
$dbForConsole = $app->getResource('dbForConsole');
/** @var Utopia\Database\Database $dbForConsole */
$leave = true;
break; // leave the do-while if successful
} catch (\Exception $e) {
Console::warning("Database not ready. Retrying connection ({$attempts})...");
if ($attempts >= $max && $rounds >= $maxRounds) {
throw new \Exception('Failed to connect to database: ' . $e->getMessage());
}
sleep($sleep);
}
} while ($attempts < $max);
$rounds++;
sleep($delay);
}
Console::success('[Setup] - Server database init started...');