()
| 578 | } |
| 579 | |
| 580 | func (t *timeoutCoordinator) Close() error { |
| 581 | return t.conn.Close() |
| 582 | } |
| 583 | |
| 584 | func (t *timeoutCoordinator) findCoordinator(req findCoordinatorRequestV0) (findCoordinatorResponseV0, error) { |
| 585 | if err := t.conn.SetDeadline(time.Now().Add(t.timeout)); err != nil { |