()
| 1771 | } |
| 1772 | |
| 1773 | func (rt *retryThrottler) successfulRPC() { |
| 1774 | if rt == nil { |
| 1775 | return |
| 1776 | } |
| 1777 | rt.mu.Lock() |
| 1778 | defer rt.mu.Unlock() |
| 1779 | rt.tokens += rt.ratio |
| 1780 | if rt.tokens > rt.max { |
| 1781 | rt.tokens = rt.max |
| 1782 | } |
| 1783 | } |
| 1784 | |
| 1785 | func (ac *addrConn) incrCallsStarted() { |
| 1786 | ac.channelz.ChannelMetrics.CallsStarted.Add(1) |