fix(rpc-gateway): tie the upstream pubsub socket to the client connection

[KishiTheMechanic]

症状

slv-rpc-gateway がクライアント 1 本につき 1 本開く upstream pubsub WebSocket が、クライアントが去っても閉じない。

〔実測 2026-09-04 indexed-ty6-1〕クライアント接続 3 本・validator 側の実サブスクリプション 13 件に対して、127.0.0.1:7212 への upstream が 343 本。プロセスの fd の 97% がこれで、RSS 600 MB。全接続が bytes_sent:356 bytes_acked:357 で以後無通信〔ss -Htnim〕= WS upgrade と 1 メソッドだけ送って、あとは何もしないまま閉じない。増加率 0.85 本/分 で、LimitNOFILE=65536 まで約 55 日。

機序

connect_loop は writer か reader のどちらかが終わったときにしか終了しないが、どちらも終わらない条件が普通に起きる。

• writer は up_rx.recv() で待つ。この channel の sender は connect_loop 自身が持っている — ローカル束縛の up_tx と、自分が握る Arc<Inner> 経由で State::Open { tx } に入っているクローン。PubsubForward を drop しても 3 本目の参照が消えるだけで、channel は開いたまま。
• reader は upstream からフレームが来たときにしか起きない。静かな購読をしてから去ったクライアントではフレームが来ないので stream.next() が永久にブロックする。

⇒ tokio::select! が発火せず、task と TCP socket が漏れる。

修正

PubsubForward に oneshot::Sender<()> を持たせ、その receiver を connect_loop の select! に足す。クライアント接続が終わって ConnectionState がスコープを抜けると PubsubForward が drop され、sender が落ちて receiver が解決し、socket が畳まれる。

検証

回帰テスト upstream_pubsub_socket_closes_when_client_disconnects を追加。upstream モックは subscribe に応答したあと沈黙し、read 側が close を観測したら oneshot で報告する。クライアントを unsubscribe せずに drop し、5 秒以内に upstream が閉じることを要求する。

• 修正あり: 60 passed; 0 failed
• 陰性対照 — select! から _ = closed_rx => {} の 1 行だけ外して同じテストを撃つ → panicked ... upstream socket must close when the client disconnects: Elapsed(()) / test result: FAILED

🤖 Generated with Claude Code