(brokers []*Broker)
| 685 | } |
| 686 | |
| 687 | func (client *client) checkSeedBrokersHealth(brokers []*Broker) { |
| 688 | if len(brokers) == 0 { |
| 689 | return |
| 690 | } |
| 691 | |
| 692 | for _, broker := range brokers { |
| 693 | if err := broker.getSockError(); err != nil { |
| 694 | Logger.Printf("client/seedbrokers close seed broker #%d at %s due to socket error: %v", broker.ID(), broker.Addr(), err) |
| 695 | safeAsyncClose(broker) |
| 696 | } |
| 697 | } |
| 698 | } |
| 699 | |
| 700 | func (client *client) checkBrokersHealth() { |
| 701 | for id, broker := range client.brokers { |
no test coverage detected