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

Tune coroutine HTTP memory budget

Browse Source
This commit is contained in:
Chirag Aggarwal
2026-04-06 08:53:06 +05:30
parent 5d6bf5cd30
commit dacb03053e
1 changed files with 21 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/http.php
+21 -2
View File
@@ -60,11 +60,24 @@ function parseMemoryLimitToBytes(string|false $memoryLimit): int
};
}
$minimumCoroutineMemoryLimit = System::getEnv('_APP_HTTP_COROUTINE_MEMORY_LIMIT', '1G');
$memoryLimitBytes = parseMemoryLimitToBytes(\ini_get('memory_limit'));
$minimumCoroutineMemoryLimitBytes = parseMemoryLimitToBytes($minimumCoroutineMemoryLimit);
if (
$minimumCoroutineMemoryLimitBytes > 0
&& $memoryLimitBytes > 0
&& $memoryLimitBytes < $minimumCoroutineMemoryLimitBytes
) {
\ini_set('memory_limit', $minimumCoroutineMemoryLimit);
$memoryLimitBytes = parseMemoryLimitToBytes(\ini_get('memory_limit'));
}
$payloadSize = 12 * (1024 * 1024); // 12MB - adding slight buffer for headers and other data that might be sent with the payload - update later with valid testing
$requestMemoryBudget = $payloadSize * 8;
$requestMemoryBudget = max($payloadSize * 8, 256 * 1024 * 1024);
$memoryReserve = 256 * 1024 * 1024;
$computedMaxConcurrency = max(1, (int) floor(max($memoryLimitBytes - $memoryReserve, $requestMemoryBudget) / $requestMemoryBudget));
$availableRequestMemory = max($memoryLimitBytes - $memoryReserve, 0);
$computedMaxConcurrency = 1;
$maxConcurrency = (int) System::getEnv('_APP_HTTP_COROUTINE_MAX_CONCURRENCY', $computedMaxConcurrency);
$swooleAdapter = new Server(
@@ -389,6 +402,7 @@ $swooleAdapter->onStart(function () use ($payloadSize, $swooleAdapter, $maxConcu
Span::init('http.server.start');
Span::add('server.adapter', 'swoole-coroutine');
Span::add('server.memory_limit', \ini_get('memory_limit'));
Span::add('server.payload_size', $payloadSize);
Span::add('server.max_concurrency', $maxConcurrency);
Span::current()?->finish();
@@ -533,6 +547,11 @@ $swooleAdapter->onRequest(function ($utopiaRequest, $utopiaResponse) use ($files
$request->resetFilters();
$request->setRoute(null);
$response->resetFilters();
gc_collect_cycles();
if (\function_exists('gc_mem_caches')) {
gc_mem_caches();
}
}
});