mirror of
https://github.com/seaweedfs/seaweedfs.git
synced 2024-01-19 02:48:24 +00:00
fix error reporting
This commit is contained in:
parent
eb493283dd
commit
c03bb180eb
|
@ -14,6 +14,9 @@ func WalkIndexFile(r io.ReaderAt, fn func(key types.NeedleId, offset types.Offse
|
||||||
var readerOffset int64
|
var readerOffset int64
|
||||||
bytes := make([]byte, types.NeedleMapEntrySize*RowsToRead)
|
bytes := make([]byte, types.NeedleMapEntrySize*RowsToRead)
|
||||||
count, e := r.ReadAt(bytes, readerOffset)
|
count, e := r.ReadAt(bytes, readerOffset)
|
||||||
|
if count == 0 && e == io.EOF {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
glog.V(3).Infof("readerOffset %d count %d err: %v", readerOffset, count, e)
|
glog.V(3).Infof("readerOffset %d count %d err: %v", readerOffset, count, e)
|
||||||
readerOffset += int64(count)
|
readerOffset += int64(count)
|
||||||
var (
|
var (
|
||||||
|
|
Loading…
Reference in a new issue