|
@ -10,7 +10,6 @@ import ( |
|
|
|
|
|
|
|
|
type ChunkGroup struct { |
|
|
type ChunkGroup struct { |
|
|
lookupFn wdclient.LookupFileIdFunctionType |
|
|
lookupFn wdclient.LookupFileIdFunctionType |
|
|
chunkCache chunk_cache.ChunkCache |
|
|
|
|
|
sections map[SectionIndex]*FileChunkSection |
|
|
sections map[SectionIndex]*FileChunkSection |
|
|
sectionsLock sync.RWMutex |
|
|
sectionsLock sync.RWMutex |
|
|
readerCache *ReaderCache |
|
|
readerCache *ReaderCache |
|
@ -19,7 +18,6 @@ type ChunkGroup struct { |
|
|
func NewChunkGroup(lookupFn wdclient.LookupFileIdFunctionType, chunkCache chunk_cache.ChunkCache, chunks []*filer_pb.FileChunk) (*ChunkGroup, error) { |
|
|
func NewChunkGroup(lookupFn wdclient.LookupFileIdFunctionType, chunkCache chunk_cache.ChunkCache, chunks []*filer_pb.FileChunk) (*ChunkGroup, error) { |
|
|
group := &ChunkGroup{ |
|
|
group := &ChunkGroup{ |
|
|
lookupFn: lookupFn, |
|
|
lookupFn: lookupFn, |
|
|
chunkCache: chunkCache, |
|
|
|
|
|
sections: make(map[SectionIndex]*FileChunkSection), |
|
|
sections: make(map[SectionIndex]*FileChunkSection), |
|
|
readerCache: NewReaderCache(32, chunkCache, lookupFn), |
|
|
readerCache: NewReaderCache(32, chunkCache, lookupFn), |
|
|
} |
|
|
} |
|
|