()
| 279 | } |
| 280 | |
| 281 | func (w *Watcher) stopDispatch() { |
| 282 | if w.dispatchCancel != nil { |
| 283 | w.dispatchCancel() |
| 284 | w.dispatchCancel = nil |
| 285 | } |
| 286 | w.dispatchMu.Lock() |
| 287 | w.pendingOrder = nil |
| 288 | w.pendingUpdates = nil |
| 289 | if w.dispatchCond != nil { |
| 290 | w.dispatchCond.Broadcast() |
| 291 | } |
| 292 | w.dispatchMu.Unlock() |
| 293 | w.clientsMutex.Lock() |
| 294 | w.authQueue = nil |
| 295 | w.clientsMutex.Unlock() |
| 296 | } |
| 297 | |
| 298 | func authEqual(a, b *coreauth.Auth) bool { |
| 299 | return reflect.DeepEqual(normalizeAuth(a), normalizeAuth(b)) |
no outgoing calls