()
| 412 | } |
| 413 | |
| 414 | func (c *connection) initFDOperator() { |
| 415 | poll := pollmanager.Pick() |
| 416 | op := poll.Alloc() |
| 417 | op.FD = c.fd |
| 418 | op.OnRead, op.OnWrite, op.OnHup = nil, nil, c.onHup |
| 419 | op.Inputs, op.InputAck = c.inputs, c.inputAck |
| 420 | op.Outputs, op.OutputAck = c.outputs, c.outputAck |
| 421 | c.operator = op |
| 422 | } |
| 423 | |
| 424 | func (c *connection) initFinalizer() { |
| 425 | c.AddCloseCallback(func(connection Connection) (err error) { |