diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-09-11 11:43:13 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-09-11 11:43:13 -0700 |
| commit | 75de7002ff028c419995b355db54c8ffc7544748 (patch) | |
| tree | b3edb91dab76f35e482aa27106543957a52addc7 | |
| parent | 9d4bdfcfdf7acb4700d52f6a8c0d080b9a7a1825 (diff) | |
| download | seaweedfs-75de7002ff028c419995b355db54c8ffc7544748.tar.xz seaweedfs-75de7002ff028c419995b355db54c8ffc7544748.zip | |
adjust size
| -rw-r--r-- | unmaintained/diff_volume_servers/diff_volume_servers.go | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/unmaintained/diff_volume_servers/diff_volume_servers.go b/unmaintained/diff_volume_servers/diff_volume_servers.go index 6107f3d48..137cb82cf 100644 --- a/unmaintained/diff_volume_servers/diff_volume_servers.go +++ b/unmaintained/diff_volume_servers/diff_volume_servers.go @@ -158,6 +158,9 @@ func getVolumeFiles(v uint32, addr string) (map[types.NeedleId]needleState, int6 files := map[types.NeedleId]needleState{} err = idx.WalkIndexFile(idxFile, func(key types.NeedleId, offset types.Offset, size types.Size) error { if offset.IsZero() || size.IsDeleted() { + if size < 0 { + size = -size + } files[key] = needleState{ state: stateDeleted, size: size, |