(err error)
| 334 | } |
| 335 | |
| 336 | func (sm *StreamManager) handleError(err error) { |
| 337 | sm.lock.Lock() |
| 338 | defer sm.lock.Unlock() |
| 339 | |
| 340 | log.Printf("handleError: PTY error=%v, totalSize=%d", err, sm.buf.TotalSize()) |
| 341 | sm.eofPos = sm.buf.TotalSize() |
| 342 | sm.terminalEvent = &streamTerminalEvent{err: err.Error()} |
| 343 | sm.drainCond.Signal() |
| 344 | } |
| 345 | |
| 346 | func (sm *StreamManager) senderLoop() { |
| 347 | for { |