| 698 | } |
| 699 | |
| 700 | func (client *client) checkBrokersHealth() { |
| 701 | for id, broker := range client.brokers { |
| 702 | if err := broker.getSockError(); err != nil { |
| 703 | Logger.Printf("client/brokers close broker #%d at %s due to socket error: %v", broker.ID(), broker.Addr(), err) |
| 704 | safeAsyncClose(broker) |
| 705 | delete(client.brokers, id) |
| 706 | } |
| 707 | } |
| 708 | |
| 709 | client.checkSeedBrokersHealth(client.seedBrokers) |
| 710 | client.checkSeedBrokersHealth(client.deadSeeds) |
| 711 | } |
| 712 | |
| 713 | func (client *client) updateBroker(brokers []*Broker) { |
| 714 | if client.brokers == nil { |