(clientID int, fn context.CancelFunc)
| 226 | } |
| 227 | |
| 228 | func (m *MultiClient) registerCancelFn(clientID int, fn context.CancelFunc) int { |
| 229 | m.inProgressMu.Lock() |
| 230 | defer m.inProgressMu.Unlock() |
| 231 | |
| 232 | m.inProgressCnt++ |
| 233 | id := m.inProgressCnt |
| 234 | m.inProgress[id] = clientInProgress{client: clientID, cancel: fn} |
| 235 | return id |
| 236 | } |
| 237 | |
| 238 | func (m *MultiClient) unregisterCancelFn(id int) { |
| 239 | m.inProgressMu.Lock() |
no outgoing calls
no test coverage detected