aboutsummaryrefslogtreecommitdiff
path: root/weed/storage/volume_read_write.go
diff options
context:
space:
mode:
authorChris Lu <chrislusf@users.noreply.github.com>2018-07-24 02:19:06 -0700
committerGitHub <noreply@github.com>2018-07-24 02:19:06 -0700
commit0fb4f59fa601eb39c1718a41dca51a05f6b3e5bb (patch)
tree96a91af29567446f49ce5cda459b6d9437e7f233 /weed/storage/volume_read_write.go
parente8a5ee4f480f1e7d4c751ccd0b303e2a001568d0 (diff)
parent77fadab56005d0a0a1b69e06e1c057ddd5a45893 (diff)
downloadseaweedfs-0fb4f59fa601eb39c1718a41dca51a05f6b3e5bb.tar.xz
seaweedfs-0fb4f59fa601eb39c1718a41dca51a05f6b3e5bb.zip
Merge pull request #697 from chrislusf/add_version3
Add version3
Diffstat (limited to 'weed/storage/volume_read_write.go')
-rw-r--r--weed/storage/volume_read_write.go13
1 files changed, 0 insertions, 13 deletions
diff --git a/weed/storage/volume_read_write.go b/weed/storage/volume_read_write.go
index 3e36bfb2e..3e711708e 100644
--- a/weed/storage/volume_read_write.go
+++ b/weed/storage/volume_read_write.go
@@ -203,19 +203,6 @@ func ScanVolumeFile(dirname string, collection string, id VolumeId,
//err = fmt.Errorf("cannot read needle body: %v", err)
//return
}
- if n.DataSize >= n.Size {
- // this should come from a bug reported on #87 and #93
- // fixed in v0.69
- // remove this whole "if" clause later, long after 0.69
- oldRest, oldSize := rest, n.Size
- padding := NeedlePaddingSize - ((n.Size + NeedleEntrySize + NeedleChecksumSize) % NeedlePaddingSize)
- n.Size = 0
- rest = int64(n.Size + NeedleChecksumSize + padding)
- if rest%NeedlePaddingSize != 0 {
- rest += (NeedlePaddingSize - rest%NeedlePaddingSize)
- }
- glog.V(4).Infof("Adjusting n.Size %d=>0 rest:%d=>%d %+v", oldSize, oldRest, rest, n)
- }
}
err = visitNeedle(n, offset)
if err == io.EOF {