()
| 422 | } |
| 423 | |
| 424 | func (c *connection) initFinalizer() { |
| 425 | c.AddCloseCallback(func(connection Connection) (err error) { |
| 426 | c.stop(flushing) |
| 427 | c.operator.Free() |
| 428 | if err = c.netFD.Close(); err != nil { |
| 429 | logger.Printf("NETPOLL: netFD close failed: %v", err) |
| 430 | } |
| 431 | c.closeBuffer() |
| 432 | return nil |
| 433 | }) |
| 434 | } |
| 435 | |
| 436 | func (c *connection) triggerRead(err error) { |
| 437 | select { |
no test coverage detected