@@ -600,6 +600,8 @@ func (s *Server) workspaceAgentPTY(rw http.ResponseWriter, r *http.Request) {
600
600
if ! ok {
601
601
return
602
602
}
603
+ log := s .Logger .With (slog .F ("agent_id" , appToken .AgentID ))
604
+ log .Debug (ctx , "resolved PTY request" )
603
605
604
606
values := r .URL .Query ()
605
607
parser := httpapi .NewQueryParamParser ()
@@ -632,19 +634,22 @@ func (s *Server) workspaceAgentPTY(rw http.ResponseWriter, r *http.Request) {
632
634
633
635
agentConn , release , err := s .WorkspaceConnCache .Acquire (appToken .AgentID )
634
636
if err != nil {
635
- s . Logger .Debug (ctx , "dial workspace agent" , slog .Error (err ))
637
+ log .Debug (ctx , "dial workspace agent" , slog .Error (err ))
636
638
_ = conn .Close (websocket .StatusInternalError , httpapi .WebsocketCloseSprintf ("dial workspace agent: %s" , err ))
637
639
return
638
640
}
639
641
defer release ()
642
+ log .Debug (ctx , "dialed workspace agent" )
640
643
ptNetConn , err := agentConn .ReconnectingPTY (ctx , reconnect , uint16 (height ), uint16 (width ), r .URL .Query ().Get ("command" ))
641
644
if err != nil {
642
- s . Logger .Debug (ctx , "dial reconnecting pty server in workspace agent" , slog .Error (err ))
645
+ log .Debug (ctx , "dial reconnecting pty server in workspace agent" , slog .Error (err ))
643
646
_ = conn .Close (websocket .StatusInternalError , httpapi .WebsocketCloseSprintf ("dial: %s" , err ))
644
647
return
645
648
}
646
649
defer ptNetConn .Close ()
650
+ log .Debug (ctx , "obtained PTY" )
647
651
agentssh .Bicopy (ctx , wsNetConn , ptNetConn )
652
+ log .Debug (ctx , "pty Bicopy finished" )
648
653
}
649
654
650
655
// wsNetConn wraps net.Conn created by websocket.NetConn(). Cancel func
0 commit comments