gitlab-com-seaweedfs/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2024-01-19 02:48:24 +00:00
Code Issues Projects Releases Wiki Activity

Log volumeId if dataFileSize != actual data file size

Browse source
This commit is contained in:
brstgt 2017-01-20 11:52:23 +01:00
parent c8f54aad8b
commit 0c898df430
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
weed/storage/volume_read_write.go
View file

@ -61,7 +61,7 @@ func (v *Volume) AppendBlob(b []byte) (offset int64, err error) {
glog.V(0).Infof("failed to seek the end of file: %v", err) glog.V(0).Infof("failed to seek the end of file: %v", err)
return return
} else if offset != int64(v.dataFileSize) { } else if offset != int64(v.dataFileSize) {
glog.V(0).Infof("dataFileSize %d != actual data file size: %d", v.dataFileSize, offset) glog.V(0).Infof("dataFileSize %d != actual data file size: %d, volumeId: %s", v.dataFileSize, offset, v.Id.String())
} }
//ensure file writing starting from aligned positions //ensure file writing starting from aligned positions
if offset%NeedlePaddingSize != 0 { if offset%NeedlePaddingSize != 0 {
@ -70,7 +70,7 @@ func (v *Volume) AppendBlob(b []byte) (offset int64, err error) {
glog.V(0).Infof("failed to align in datafile %s: %v", v.dataFile.Name(), err) glog.V(0).Infof("failed to align in datafile %s: %v", v.dataFile.Name(), err)
return return
} else if offset != int64(v.dataFileSize) { } else if offset != int64(v.dataFileSize) {
glog.V(0).Infof("dataFileSize %d != actual data file size: %d", v.dataFileSize, offset) glog.V(0).Infof("dataFileSize %d != actual data file size: %d, volumeId: %s", v.dataFileSize, offset, v.Id.String())
} }
} }
_, err = v.dataFile.Write(b) _, err = v.dataFile.Write(b)
@ -96,7 +96,7 @@ func (v *Volume) writeNeedle(n *Needle) (size uint32, err error) {
glog.V(0).Infof("failed to seek the end of file: %v", err) glog.V(0).Infof("failed to seek the end of file: %v", err)
return return
} else if offset != int64(v.dataFileSize) { } else if offset != int64(v.dataFileSize) {
glog.V(0).Infof("dataFileSize %d != actual data file size: %d", v.dataFileSize, offset) glog.V(0).Infof("dataFileSize %d != actual data file size: %d, volumeId: %s", v.dataFileSize, offset, v.Id.String())
} }
//ensure file writing starting from aligned positions //ensure file writing starting from aligned positions
@ -146,7 +146,7 @@ func (v *Volume) deleteNeedle(n *Needle) (uint32, error) {
if offset, err := v.dataFile.Seek(0, 2); err != nil { if offset, err := v.dataFile.Seek(0, 2); err != nil {
return size, err return size, err
} else if offset != int64(v.dataFileSize) { } else if offset != int64(v.dataFileSize) {
glog.V(0).Infof("dataFileSize %d != actual data file size: %d, deleteMarker: %d", v.dataFileSize, offset, getActualSize(0)) glog.V(0).Infof("dataFileSize %d != actual data file size: %d, deleteMarker: %d, volumeId: %s", v.dataFileSize, offset, getActualSize(0), v.Id.String())
} }
n.Data = nil n.Data = nil
_, actualSize, err := n.Append(v.dataFile, v.Version()) _, actualSize, err := n.Append(v.dataFile, v.Version())