KJZH001/nezhahq-agent
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: WebSSH 无法退出，关闭后 CPU 100%

Browse Source
This commit is contained in:
naiba 2024-08-13 09:53:01 +08:00
parent f4d9db28a2
commit f20bea757b
1 changed files with 14 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
cmd/agent/main.go
View File

@ -701,12 +701,25 @@ func handleTerminalTask(task *pb.Task) {
println("terminal init", terminal.StreamID)
clientIn, stdinPipe := io.Pipe()
defer stdinPipe.Close()
stdoutPipe, clientOut := io.Pipe()
defer stdinPipe.Close()
defer clientOut.Close()
ttyForFilter, ttyForFilterWriter := io.Pipe()
defer ttyForFilterWriter.Close()
go func() {
io.Copy(ttyForFilterWriter, tty)
stdoutPipe.Close()
}()
width, _, err := tty.Getsize()
if err != nil {
println("Terminal tty.Getsize失败：", err)
}
trzszFilter := trzsz.NewTrzszFilter(clientIn, clientOut, tty, tty, trzsz.TrzszOptions{TerminalColumns: int32(width), EnableZmodem: true})
trzszFilter := trzsz.NewTrzszFilter(clientIn, clientOut, tty, ttyForFilter, trzsz.TrzszOptions{TerminalColumns: int32(width), EnableZmodem: true})
defer trzszFilter.StopTransferringFiles(true)
go func() {
for {