(listener net.Listener, addr string)
| 261 | } |
| 262 | |
| 263 | func (c *SecureShell) localForwardAcceptLoop(listener net.Listener, addr string) { |
| 264 | defer listener.Close() |
| 265 | |
| 266 | for { |
| 267 | conn, err := listener.Accept() |
| 268 | if err != nil { |
| 269 | //nolint:staticcheck |
| 270 | if netErr, ok := err.(net.Error); ok && netErr.Temporary() { |
| 271 | time.Sleep(100 * time.Millisecond) |
| 272 | continue |
| 273 | } |
| 274 | return |
| 275 | } |
| 276 | |
| 277 | go c.handleForwardConnection(conn, addr) |
| 278 | } |
| 279 | } |
| 280 | |
| 281 | func (c *SecureShell) resize(resized <-chan os.Signal, session SecureSession, terminalFd uintptr) { |
| 282 | type resizeMessage struct { |
no test coverage detected