Concurrent-safe get value of nextSequence
()
| 990 | |
| 991 | // Concurrent-safe get value of nextSequence |
| 992 | func (c *changeCache) getNextSequence() (nextSequence uint64) { |
| 993 | c.lock.RLock() |
| 994 | nextSequence = c.nextSequence |
| 995 | c.lock.RUnlock() |
| 996 | return nextSequence |
| 997 | } |
| 998 | |
| 999 | // ////// LOG PRIORITY QUEUE -- container/heap callbacks that should not be called directly. Use heap.Init/Push/etc() |
| 1000 |