diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-08-18 17:39:29 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-08-18 17:39:29 -0700 |
| commit | c026eb05921b180cad0b529634ff4c891cb5b61f (patch) | |
| tree | d43528feaae85f8e709afaac924ccf4ff43c021e /unmaintained/diff_volume_servers | |
| parent | 7e91ae592c2e34506b040c08d3aecbbdbe3781d1 (diff) | |
| download | seaweedfs-c026eb05921b180cad0b529634ff4c891cb5b61f.tar.xz seaweedfs-c026eb05921b180cad0b529634ff4c891cb5b61f.zip | |
refactoring
Diffstat (limited to 'unmaintained/diff_volume_servers')
| -rw-r--r-- | unmaintained/diff_volume_servers/diff_volume_servers.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/unmaintained/diff_volume_servers/diff_volume_servers.go b/unmaintained/diff_volume_servers/diff_volume_servers.go index 339d9c335..4de864980 100644 --- a/unmaintained/diff_volume_servers/diff_volume_servers.go +++ b/unmaintained/diff_volume_servers/diff_volume_servers.go @@ -155,7 +155,7 @@ func getVolumeFiles(v uint32, addr string) (map[types.NeedleId]needleState, int6 var maxOffset int64 files := map[types.NeedleId]needleState{} err = idx.WalkIndexFile(idxFile, func(key types.NeedleId, offset types.Offset, size types.Size) error { - if offset.IsZero() || size < 0 || size == types.TombstoneFileSize { + if offset.IsZero() || size.IsDeleted() { files[key] = needleState{ state: stateDeleted, size: size, |
