()
| 532 | } |
| 533 | |
| 534 | func (wm *watchManager) close() error { |
| 535 | wm.muClosed.Lock() |
| 536 | defer wm.muClosed.Unlock() |
| 537 | |
| 538 | if wm.closed { |
| 539 | return ErrWatchManagerClosed |
| 540 | } |
| 541 | |
| 542 | wm.workerCancel() |
| 543 | wm.closed = true |
| 544 | |
| 545 | return nil |
| 546 | } |
| 547 | |
| 548 | func (wm *watchManager) findSubscriber(bucketName core.BucketName, key string, id uint64) (*subscriber, error) { |
| 549 | if _, ok := wm.lookup[bucketName]; !ok { |
no outgoing calls