619
if (existing) {
620
if (replaceRelay) {
622
>
// the same dispose-and-recreate pattern as TunnelAgentHostMainService.
623
>
// The SSH client is detached so only the WebSocket relay is closed.
624
>
this._logService.info(`${LOG_PREFIX} Reconnecting relay for existing SSH tunnel ${connectionKey}`);
625
>
const { sshClient, remotePort, connectionToken } = existing;
626
>
627
>
// Remove from map and detach SSH client before disposing so
628
>
// the old relay's close handler (conn?.dispose()) is a no-op.
629
>
this._connections.deleteAndLeak(connectionKey);
630
>
existing.detachSshClient();
631
>
existing.dispose();
632
>
633
>
// Create fresh relay and connection. If relay creation fails,
634
>
// clean up the detached SSH client so it doesn't leak.
635
>
const connectionId = connectionKey;
636
>
try {
637
>
let conn: SSHConnection | undefined; // eslint-disable-line prefer-const
638
>
// Bound the relay creation: a silently dead SSH client
639
>
// (TCP half-open, ssh2 keepalive hasn't fired yet) can
640
>
// leave forwardOut's callback unfired, hanging the whole
641
>
// promise chain. raceTimeout returns undefined on timeout.
642
>
const timeoutMs = this.relayCreationTimeoutMs;
643
>
const relay = await raceTimeout(
644
>
this._createWebSocketRelay(
645
>
sshClient, '127.0.0.1', remotePort, connectionToken,
646
>
(data: string) => this._onDidRelayMessage.fire({ connectionId, data }),
647
>
() => { conn?.dispose(); },
648
>
),
649
>
timeoutMs,
650
>
);
651
if (!relay) {
652
throw new Error(`SSH relay creation timed out after ${timeoutMs}ms (SSH client appears unresponsive)`);