()
| 33 | ) |
| 34 | |
| 35 | func (db *DatabaseContext) CacheCompactActive() bool { |
| 36 | channelCache := db.changeCache.getChannelCache() |
| 37 | compactingCache, ok := channelCache.(*channelCacheImpl) |
| 38 | if !ok { |
| 39 | return false |
| 40 | } |
| 41 | return compactingCache.isCompactActive() |
| 42 | } |
| 43 | |
| 44 | func (db *DatabaseContext) WaitForCaughtUp(targetCount int64) error { |
| 45 | for i := 0; i < 100; i++ { |