CodeMirror/appwrite
1
0
Fork 0
mirror of synced 2024-06-27 02:31:04 +12:00
Code Issues Projects Releases Wiki Activity

move connections back into pool after used

Browse source
This commit is contained in:
Torsten Dittmann 2021-03-12 16:56:41 +01:00
parent 56dca6b172
commit 520c065236
1 changed files with 17 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
app/realtime.php
View file

@ -6,6 +6,8 @@ use Appwrite\Network\Validator\Origin;
use Appwrite\Realtime\Realtime;
use Appwrite\Utopia\Response;
use Swoole\Database\PDOProxy;
use Swoole\Database\RedisConfig;
use Swoole\Database\RedisPool;
use Swoole\Process;
use Swoole\Http\Request;
use Swoole\Http\Response as SwooleResponse;
@ -206,6 +208,21 @@ $server->on('open', function (Server $server, Request $request) use (&$connectio
Realtime::subscribe($project->getId(), $connection, $roles, $subscriptions, $connections, $channels);
$server->push($connection, json_encode($channels));
/**
* Put used PDO and Redis Connections back into their pools.
*/
/** @var Swoole\Database\PDOPool $dbPool */
$dbPool = $register->get('dbPool');
$dbPool->put(new PDOProxy(function () use ($register) {
return $register->get('db');
}
));
/** @var Swoole\Database\RedisPool $redisPool */
$redisPool = $register->get('redisPool');
$redisPool->put($register->get('cache'));
} catch (\Throwable $th) {
$response = [
'code' => $th->getCode(),