(dataEntries map[int]*DataCacheEntry, parts []int)
| 260 | } |
| 261 | |
| 262 | func prunePartsWithCache(dataEntries map[int]*DataCacheEntry, parts []int) []int { |
| 263 | var rtn []int |
| 264 | for _, partIdx := range parts { |
| 265 | if dataEntries[partIdx] != nil { |
| 266 | continue |
| 267 | } |
| 268 | rtn = append(rtn, partIdx) |
| 269 | } |
| 270 | return rtn |
| 271 | } |
| 272 | |
| 273 | func (entry *CacheEntry) loadDataPartsIntoCache(ctx context.Context, parts []int) error { |
| 274 | parts = prunePartsWithCache(entry.DataEntries, parts) |
no outgoing calls
no test coverage detected