Skip to content

Commit 8d3d98b

Browse files
committed
WIP
1 parent ef1bb6f commit 8d3d98b

File tree

2 files changed

+5
-5
lines changed

2 files changed

+5
-5
lines changed

cli/ssh.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -411,11 +411,11 @@ func (r *RootCmd) ssh() *serpent.Command {
411411
slog.F("agent_status", workspaceAgent.Status),
412412
slog.F("immortal_fallback_enabled", immortalFallback))
413413

414-
shouldFallback := immortalFallback && (strings.Contains(err.Error(), "too many immortal streams") ||
414+
shouldFallback := immortalFallback && (strings.Contains(err.Error(), "Too many immortal streams") ||
415415
strings.Contains(err.Error(), "The connection was refused"))
416416

417417
if shouldFallback {
418-
if strings.Contains(err.Error(), "too many immortal streams") {
418+
if strings.Contains(err.Error(), "Too many immortal streams") {
419419
logger.Warn(ctx, "too many immortal streams, falling back to regular SSH connection",
420420
slog.F("max_streams", "32"))
421421
} else {
@@ -528,11 +528,11 @@ func (r *RootCmd) ssh() *serpent.Command {
528528
slog.F("agent_status", workspaceAgent.Status),
529529
slog.F("immortal_fallback_enabled", immortalFallback))
530530

531-
shouldFallback := immortalFallback && (strings.Contains(err.Error(), "too many immortal streams") ||
531+
shouldFallback := immortalFallback && (strings.Contains(err.Error(), "Too many immortal streams") ||
532532
strings.Contains(err.Error(), "The connection was refused"))
533533

534534
if shouldFallback {
535-
if strings.Contains(err.Error(), "too many immortal streams") {
535+
if strings.Contains(err.Error(), "Too many immortal streams") {
536536
logger.Warn(ctx, "too many immortal streams, falling back to regular SSH connection",
537537
slog.F("max_streams", "32"))
538538
} else {

coderd/workspaceagents.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -915,7 +915,7 @@ func (api *API) workspaceAgentCreateImmortalStream(rw http.ResponseWriter, r *ht
915915
stream, err := agentConn.CreateImmortalStream(ctx, req)
916916
if err != nil {
917917
// Check for specific error types from the agent
918-
if strings.Contains(err.Error(), "too many immortal streams") {
918+
if strings.Contains(err.Error(), "Too many Immortal Streams") {
919919
httpapi.Write(ctx, rw, http.StatusServiceUnavailable, codersdk.Response{
920920
Message: "Too many immortal streams.",
921921
})

0 commit comments

Comments
 (0)