()
| 324 | } |
| 325 | |
| 326 | func (sm *StreamManager) handleEOF() { |
| 327 | sm.lock.Lock() |
| 328 | defer sm.lock.Unlock() |
| 329 | |
| 330 | log.Printf("handleEOF: PTY reached EOF, totalSize=%d", sm.buf.TotalSize()) |
| 331 | sm.eofPos = sm.buf.TotalSize() |
| 332 | sm.terminalEvent = &streamTerminalEvent{isEof: true} |
| 333 | sm.drainCond.Signal() |
| 334 | } |
| 335 | |
| 336 | func (sm *StreamManager) handleError(err error) { |
| 337 | sm.lock.Lock() |