Github-Mirror/seaweedfs
1
0 Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2026-11-11 14:28:33 +01:00
Code Issues Packages Projects Releases Wiki Activity

correct cache: fix racing condition

Browse Source
This commit is contained in:
chrislusf committed 2016-04-17 12:03:45 -07:00
1 parent 6dd257a81f
commit adcfaa5735
2 files changed
+7 -9
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

go/storage/needle_read_write.go
+1 -6
View File
@@ -139,12 +139,7 @@ func (n *Needle) Append(w io.Writer, version Version) (size uint32, err error) {
func ReadNeedleBlob(r *os.File, offset int64, size uint32) (dataSlice []byte, block *Block, err error) {
padding := NeedlePaddingSize - ((NeedleHeaderSize + size + NeedleChecksumSize) % NeedlePaddingSize)
readSize := NeedleHeaderSize + size + NeedleChecksumSize + padding
block, isNew := getBytesForFileBlock(r, offset, int(readSize))
dataSlice = block.Bytes[0:int(readSize)]
if isNew {
_, err = r.ReadAt(dataSlice, offset)
}
return dataSlice, block, err
return getBytesForFileBlock(r, offset, int(readSize))
}
func (n *Needle) ReadData(r *os.File, offset int64, size uint32, version Version) (err error) {