Updates the high cache sequence if the incoming sequence is higher than current Note: doesn't require compareAndSet on update, as cache expects AddToCache to only be called from a single goroutine
(sequence uint64)
| 168 | // Note: doesn't require compareAndSet on update, as cache expects AddToCache to only be called from |
| 169 | // a single goroutine |
| 170 | func (c *channelCacheImpl) updateHighCacheSequence(sequence uint64) { |
| 171 | c.seqLock.Lock() |
| 172 | if sequence > c.highCacheSequence { |
| 173 | c.highCacheSequence = sequence |
| 174 | } |
| 175 | c.seqLock.Unlock() |
| 176 | } |
| 177 | |
| 178 | // GetSingleChannelCache will create the cache for the channel if it doesn't exist. If the cache is at |
| 179 | // capacity, will return a bypass channel cache. |
no test coverage detected