Fix base reader

picosh · Nov 17, 2024 · a32d467 · a32d467
1 parent 6372620
commit a32d467
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/pipe/client.go b/pipe/client.go
@@ -253,7 +253,7 @@ func Base(ctx context.Context, logger *slog.Logger, info *SSHClientInfo, id, cmd
 		return nil, err
 	}
 
-	session, err := client.AddSession(id, cmd, 0, 0, 0)
+	session, err := client.AddSession(id, cmd, 100, -1, -1)
 	if err != nil {
 		return nil, err
 	}

diff --git a/pipe/session.go b/pipe/session.go
@@ -193,7 +193,7 @@ func (s *Session) Start() {
 					n, err := s.StdoutPipe.Read(data)
 
 					select {
-					case s.Out <- SendData{Data: slices.Clone(data[:n]), N: n, Error: err}:
+					case s.Out <- SendData{Data: data[:n], N: n, Error: err}:
 						break
 					case <-s.Done:
 						s.broadcastDone()
@@ -287,5 +287,7 @@ func (s *Session) broadcastDone() {
 		break
 	case <-s.Client.CtxDone:
 		break
+	default:
+		break
 	}
 }