CodeMirror/appwrite
1
0
Fork 0
mirror of synced 2024-10-01 01:37:56 +13:00
Code Issues Projects Releases Wiki Activity

WIP fix too many connections

Browse source
This commit is contained in:
Jake Barnby 2022-11-07 23:31:54 +13:00
parent 44ca7d9459
commit a6ffab09df
No known key found for this signature in database
GPG key ID: C437A8CC85B96E9C
2 changed files with 9 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
app/realtime.php
View file

@ -35,6 +35,9 @@ Runtime::enableCoroutine(SWOOLE_HOOK_ALL);
$realtime = new Realtime(); $realtime = new Realtime();
$dbPool = $register->get('dbPool');
$redisPool = $register->get('redisPool');
/** /**
* Table for statistics across all workers. * Table for statistics across all workers.
*/ */
@ -354,15 +357,15 @@ $server->onWorkerStart(function (int $workerId) use ($server, $register, $stats,
Console::error('Failed to restart pub/sub...'); Console::error('Failed to restart pub/sub...');
}); });
$server->onOpen(function (int $connection, SwooleRequest $request) use ($server, $register, $stats, &$realtime, $logError) { $server->onOpen(function (int $connection, SwooleRequest $request) use ($server, $dbPool, $redisPool, $stats, &$realtime, $logError) {
$app = new App('UTC'); $app = new App('UTC');
$request = new Request($request); $request = new Request($request);
$response = new Response(new SwooleResponse()); $response = new Response(new SwooleResponse());
/** @var PDO $db */ /** @var PDO $db */
$db = $register->get('dbPool')->get(); $db = $dbPool->get();
/** @var Redis $redis */ /** @var Redis $redis */
$redis = $register->get('redisPool')->get(); $redis = $redisPool->get();
Console::info("Connection open (user: {$connection})"); Console::info("Connection open (user: {$connection})");
@ -477,8 +480,8 @@ $server->onOpen(function (int $connection, SwooleRequest $request) use ($server,
/** /**
* Put used PDO and Redis Connections back into their pools. * Put used PDO and Redis Connections back into their pools.
*/ */
$register->get('dbPool')->put($db); $dbPool->put($db);
$register->get('redisPool')->put($redis); $redisPool->put($redis);
} }
}); });

2
docker-compose.yml
View file

@ -707,7 +707,7 @@ services:
- MYSQL_DATABASE=${_APP_DB_SCHEMA} - MYSQL_DATABASE=${_APP_DB_SCHEMA}
- MYSQL_USER=${_APP_DB_USER} - MYSQL_USER=${_APP_DB_USER}
- MYSQL_PASSWORD=${_APP_DB_PASS} - MYSQL_PASSWORD=${_APP_DB_PASS}
command: 'mysqld --innodb-flush-method=fsync' # add ' --query_cache_size=0' for DB tests command: 'mysqld --innodb-flush-method=fsync --max_connections=49152' # 128 (CPUs) * 6 (Workers) * 64 (Pool size)
# command: mv /var/lib/mysql/ib_logfile0 /var/lib/mysql/ib_logfile0.bu && mv /var/lib/mysql/ib_logfile1 /var/lib/mysql/ib_logfile1.bu # command: mv /var/lib/mysql/ib_logfile0 /var/lib/mysql/ib_logfile0.bu && mv /var/lib/mysql/ib_logfile1 /var/lib/mysql/ib_logfile1.bu
# smtp: # smtp: