|
|
@ -81,6 +81,7 @@ func (cw *UploadPipeline) MaybeReadDataAt(p []byte, off int64) (maxStop int64) { |
|
|
|
cw.sealedChunksLock.Unlock() |
|
|
|
if found { |
|
|
|
maxStop = readMemChunk(sealedChunk.chunk, p, off, logicChunkIndex, cw.ChunkSize) |
|
|
|
glog.V(4).Infof("%s read sealed memchunk [%d,%d)", cw.filepath, off, maxStop) |
|
|
|
sealedChunk.FreeReference(fmt.Sprintf("%s finish reading chunk %d", cw.filepath, logicChunkIndex)) |
|
|
|
} |
|
|
|
|
|
|
@ -91,7 +92,9 @@ func (cw *UploadPipeline) MaybeReadDataAt(p []byte, off int64) (maxStop int64) { |
|
|
|
if !found { |
|
|
|
return |
|
|
|
} |
|
|
|
maxStop = max(maxStop, readMemChunk(writableChunk, p, off, logicChunkIndex, cw.ChunkSize)) |
|
|
|
writableMaxStop := readMemChunk(writableChunk, p, off, logicChunkIndex, cw.ChunkSize) |
|
|
|
glog.V(4).Infof("%s read writable memchunk [%d,%d)", cw.filepath, off, writableMaxStop) |
|
|
|
maxStop = max(maxStop, writableMaxStop) |
|
|
|
|
|
|
|
return |
|
|
|
} |
|
|
|