diff options
| author | chrislusf <chris.lu@gmail.com> | 2015-04-14 23:05:33 -0700 |
|---|---|---|
| committer | chrislusf <chris.lu@gmail.com> | 2015-04-14 23:05:33 -0700 |
| commit | 49d639ecabe32e02e4fc41e27bb61005fd25931d (patch) | |
| tree | e45267183a2eb4204bb2d6e927afd4dcebfe0bf5 /go/storage/volume.go | |
| parent | c28d55d343c26975cf02f394051b8a8b04c370d2 (diff) | |
| download | seaweedfs-49d639ecabe32e02e4fc41e27bb61005fd25931d.tar.xz seaweedfs-49d639ecabe32e02e4fc41e27bb61005fd25931d.zip | |
Add error checking for file reads.
Diffstat (limited to 'go/storage/volume.go')
| -rw-r--r-- | go/storage/volume.go | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/go/storage/volume.go b/go/storage/volume.go index e35eeee49..217a82373 100644 --- a/go/storage/volume.go +++ b/go/storage/volume.go @@ -152,7 +152,11 @@ func (v *Volume) isFileUnchanged(n *Needle) bool { nv, ok := v.nm.Get(n.Id) if ok && nv.Offset > 0 { oldNeedle := new(Needle) - oldNeedle.Read(v.dataFile, int64(nv.Offset)*NeedlePaddingSize, nv.Size, v.Version()) + _, err := oldNeedle.Read(v.dataFile, int64(nv.Offset)*NeedlePaddingSize, nv.Size, v.Version()) + if err != nil { + glog.V(0).Infof("Failed to check updated file %v", err) + return false + } if oldNeedle.Checksum == n.Checksum && bytes.Equal(oldNeedle.Data, n.Data) { n.DataSize = oldNeedle.DataSize return true |