(broker *Broker)
| 1736 | } |
| 1737 | |
| 1738 | func (p *asyncProducer) getBrokerProducer(broker *Broker) *brokerProducer { |
| 1739 | p.brokerLock.Lock() |
| 1740 | defer p.brokerLock.Unlock() |
| 1741 | |
| 1742 | bp := p.brokers[broker] |
| 1743 | |
| 1744 | if bp == nil { |
| 1745 | bp = p.newBrokerProducer(broker) |
| 1746 | p.brokers[broker] = bp |
| 1747 | p.brokerRefs[bp] = 0 |
| 1748 | } |
| 1749 | |
| 1750 | p.brokerRefs[bp]++ |
| 1751 | |
| 1752 | return bp |
| 1753 | } |
| 1754 | |
| 1755 | func (p *asyncProducer) unrefBrokerProducer(broker *Broker, bp *brokerProducer) { |
| 1756 | p.brokerLock.Lock() |