(address string)
| 56 | } |
| 57 | |
| 58 | func decInFlightRequest(address string) { |
| 59 | if v, ok := inFlightRequests.Load(address); ok { |
| 60 | if v.(*atomic.Int64).Add(-1) <= 0 { |
| 61 | inFlightRequests.Delete(address) |
| 62 | } |
| 63 | } |
| 64 | } |
| 65 | |
| 66 | func getInFlightRequests() map[string]int64 { |
| 67 | copyMap := make(map[string]int64) |
no test coverage detected