modelcontextprotocol / modelcontextprotocol/php-sdk

[Server] Concurrent requests corrupt the session file in FileSessionStore, crashing Session::readData() with JsonException

Abierto
#498 2 comentarios 0 reacciones 0 asignados Ver en GitHub

Nadie ha tomado este issue todavía.

bug P2 Server
Lenguaje dominante
PHP
Estrellas
1.6k
Forks
173
Merge medio
2 d 49 min
PR fusionados (30 d)
23

Descripción

Describe the bug

Under PHP-FPM, two concurrent requests carrying the same Mcp-Session-Id can leave the session file empty (0 bytes). The next read of that session throws an uncaught JsonException out of Session::readData(), and the server answers -32603 for a tool call that had already completed successfully — the tool ran, its response was queued in the session, and then the response could not be retrieved.

Two independent defects combine here; each is a necessary condition.

  1. FileSessionStore::write() uses a fixed temporary filename. $tmp = $path.'.tmp'; is identical for every concurrent writer of the same session, and file_put_contents() opens the stream in w mode — so truncation happens before LOCK_EX is acquired. One process can therefore rename() a temp file that another process has just truncated to 0 bytes, publishing an empty session file. The // Atomic move comment applies to rename() alone; the operation as a whole is not atomic because the temp name is shared. The copy() fallback has the same problem (it truncates the destination and then streams into it), and read() takes no LOCK_SH.

  2. Session::readData() does not guard against an empty string. Only false is handled, so '' reaches json_decode(..., JSON_THROW_ON_ERROR):

$rawData = $this->store->read($this->id);
if (false === $rawData) { return $this->data = []; }        // only false is handled
$decoded = json_decode($rawData, true, flags: \JSON_THROW_ON_ERROR);   // throws on ''
if (!\is_array($decoded)) { return $this->data = []; }      // unreachable for ''

FileSessionStore::read() returns '' for a zero-byte file — it returns false only when the file is missing, expired, or unreadable. This half is store-agnostic: any store that can return an empty string triggers it.

To Reproduce

Steps to reproduce the behavior:

  1. Run a server on PHP-FPM with StreamableHttpTransport and FileSessionStore (handshake era).
  2. POST an initialize request without a session id; take Mcp-Session-Id from the response headers.
  3. POST notifications/initialized with that header.
  4. Deterministic variant — truncate the session file by hand: : > <session-dir>/<session-id> (or write invalid JSON: printf '{"a":' > <session-dir>/<session-id>).
  5. POST tools/list with the same Mcp-Session-Id. The request fails with -32603 and the JsonException below.
  6. Concurrency variant (shows the actual cause rather than the symptom) — instead of step 4, fire ~40 parallel tools/list POSTs sharing one Mcp-Session-Id, e.g. seq 40 | xargs -P 8 -I{} curl -s -o /dev/null -w '%{http_code}\n' -X POST ..., and repeat a few rounds. Occasional requests fail with -32603.

Expected behavior

  1. Concurrent writes to the same session never publish a partial or empty session file.
  2. An empty or undecodable payload from the store degrades to an empty session instead of a fatal error. The existing !\is_array($decoded) branch already shows this is the intended behaviour — it is simply unreachable while JSON_THROW_ON_ERROR fires first.

Logs

JsonException: Syntax error in src/Server/Session/Session.php:168
#0 Session.php(168): json_decode('', true, 512, 4194304)
#1 Session.php(53):  Mcp\Server\Session\Session->readData()
#2 Protocol.php(517): Mcp\Server\Session\Session->get(Array, Array)
#3 BaseTransport.php(81): Mcp\Server\Protocol->consumeOutgoingMessages(Symfony\Component\Uid\UuidV4)
#4 StreamableHttpTransport.php(218): Mcp\Server\Transport\BaseTransport->getOutgoingMessages(...)
#5 StreamableHttpTransport.php(202): ...->createJsonResponse()
#6 StreamableHttpTransport.php(437): ...->handlePostRequest('{"jsonrpc":"2.0...')
#7 Server.php(67): Mcp\Server\Transport\StreamableHttpTransport->listen()

Additional context

Why the exception escapes every catch block. The crash happens in Protocol::consumeOutgoingMessages(), which builds a fresh Session instance:

// Protocol.php:516
$session = $this->sessionManager->createWithId($sessionId);
$queue = $session->get(self::SESSION_OUTGOING_QUEUE, []);   // second, independent disk read

A single POST therefore reads the session file twice, through two objects that share no memory — and the second read happens after the request's own save() at Protocol.php:223. That second read is reached from BaseTransport::getOutgoingMessages() while the response is being built, which is outside Protocol::processInput()'s try/catch (that one wraps only doProcessInput()); Server::run() has just try/finally. The exception propagates out of Server::run() into the application's own error handler.

Silent lost writes. After the losing process's rename() fails (its temp file is gone) and copy() fails too, write() returns false — but Session::save()'s return value is discarded at Protocol.php:223, :519, :551 and :644, so the failed write is invisible.

Where a fix would belong. Both halves look small and independent — the shared temp filename in FileSessionStore::write(), and the missing '' case in Session::readData().

One more observation, separate from the bug. Since #479, gc() skips anything whose filename is not a valid UUID, so orphaned *.tmp files are never cleaned up. Harmless at one temp file per session, but worth knowing if the temp name ever becomes unique.

Related but distinct issues. #275 (lost update on concurrent read-modify-write) and #467 (concurrent POSTs returning a JSON array). A per-session lock as proposed in #275 would incidentally prevent this crash, but would not close item 2.

Environment. mcp/sdk v0.8.1, PHP 8.5, PHP-FPM, StreamableHttpTransport with withoutModernEra(), FileSessionStore on local disk (Linux), TTL 14400 s. The same code is present on main, so this is not fixed by upgrading.

Guía de contribución

Abrir la guía de contribución

Primeros pasos

  1. Lee el issue completo y luego la guía de contribución del proyecto.
  2. Comenta en el issue que vas a ocuparte — evita que dos personas hagan lo mismo.
  3. Haz un fork del repositorio y trabaja en una rama.
  4. Abre un pull request que haga referencia al número del issue.

Línea de trabajo

Comienza con src/Server/Session/Session.php y las rutas FileSessionStore::write() y read(), y luego sigue la segunda lectura de sesión desde Protocol.php a través de BaseTransport::getOutgoingMessages(). Reproduce el caso de un archivo vacío y las solicitudes paralelas tools/list descritas en el issue. Se considera terminado cuando las escrituras simultáneas no publican archivos vacíos o parciales, y los datos vacíos del store se tratan como una sesión vacía sin una JsonException no capturada.

Escrito por el modelo de indexación a partir del texto del issue.

Evaluación

Stack tecnológico
php
Área
backend
Tipo de issue
Error
Dificultad
4/5
Tiempo estimado
3-5 días
Estado de actividad
Activo
Claridad
Bien especificado
Aptitud para principiantes
68/100

Recibe los nuevos issues en tu correo

Un resumen breve de issues de GitHub para principiantes.