mirror of
https://github.com/seaweedfs/seaweedfs.git
synced 2025-09-23 07:33:34 +08:00
remove case when read request is out side of the file size
This commit is contained in:
@@ -176,13 +176,12 @@ func (c *ChunkReadAt) doReadAt(p []byte, offset int64) (n int, ts int64, err err
|
|||||||
if c.fileSize >= startOffset {
|
if c.fileSize >= startOffset {
|
||||||
delta = min(remaining, c.fileSize-startOffset)
|
delta = min(remaining, c.fileSize-startOffset)
|
||||||
startOffset -= offset
|
startOffset -= offset
|
||||||
} else {
|
|
||||||
delta = remaining
|
|
||||||
startOffset = max(startOffset-offset, startOffset-remaining-offset)
|
|
||||||
}
|
}
|
||||||
|
if delta > 0 {
|
||||||
glog.V(4).Infof("zero2 [%d,%d) of file size %d bytes", startOffset, startOffset+delta, c.fileSize)
|
glog.V(4).Infof("zero2 [%d,%d) of file size %d bytes", startOffset, startOffset+delta, c.fileSize)
|
||||||
n += zero(p, startOffset, delta)
|
n += zero(p, startOffset, delta)
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
if err == nil && offset+int64(len(p)) >= c.fileSize {
|
if err == nil && offset+int64(len(p)) >= c.fileSize {
|
||||||
err = io.EOF
|
err = io.EOF
|
||||||
|
Reference in New Issue
Block a user