(address string)
| 51 | var inFlightRequests sync.Map |
| 52 | |
| 53 | func incInFlightRequest(address string) { |
| 54 | v, _ := inFlightRequests.LoadOrStore(address, new(atomic.Int64)) |
| 55 | v.(*atomic.Int64).Add(1) |
| 56 | } |
| 57 | |
| 58 | func decInFlightRequest(address string) { |
| 59 | if v, ok := inFlightRequests.Load(address); ok { |
no test coverage detected