MCPcopy Index your code
hub / github.com/wavetermdev/waveterm / loadDataPartsIntoCache

Method loadDataPartsIntoCache

pkg/filestore/blockstore_cache.go:273–287  ·  view source on GitHub ↗
(ctx context.Context, parts []int)

Source from the content-addressed store, hash-verified

271}
272
273func (entry *CacheEntry) loadDataPartsIntoCache(ctx context.Context, parts []int) error {
274 parts = prunePartsWithCache(entry.DataEntries, parts)
275 if len(parts) == 0 {
276 // parts are already loaded
277 return nil
278 }
279 dbDataParts, err := dbGetFileParts(ctx, entry.ZoneId, entry.Name, parts)
280 if err != nil {
281 return fmt.Errorf("error getting data parts: %w", err)
282 }
283 for partIdx, dce := range dbDataParts {
284 entry.DataEntries[partIdx] = dce
285 }
286 return nil
287}
288
289func (entry *CacheEntry) loadDataPartsForRead(ctx context.Context, parts []int) (map[int]*DataCacheEntry, error) {
290 if len(parts) == 0 {

Callers 3

WriteAtMethod · 0.80
AppendDataMethod · 0.80
AppendIJsonMethod · 0.80

Calls 2

prunePartsWithCacheFunction · 0.85
dbGetFilePartsFunction · 0.85

Tested by

no test coverage detected