aboutsummaryrefslogtreecommitdiff
path: root/unmaintained/diff_volume_servers/diff_volume_servers.go
diff options
context:
space:
mode:
Diffstat (limited to 'unmaintained/diff_volume_servers/diff_volume_servers.go')
-rw-r--r--unmaintained/diff_volume_servers/diff_volume_servers.go6
1 files changed, 3 insertions, 3 deletions
diff --git a/unmaintained/diff_volume_servers/diff_volume_servers.go b/unmaintained/diff_volume_servers/diff_volume_servers.go
index e0f16e2d0..339d9c335 100644
--- a/unmaintained/diff_volume_servers/diff_volume_servers.go
+++ b/unmaintained/diff_volume_servers/diff_volume_servers.go
@@ -118,7 +118,7 @@ const (
type needleState struct {
state uint8
- size uint32
+ size types.Size
}
func getVolumeFiles(v uint32, addr string) (map[types.NeedleId]needleState, int64, error) {
@@ -154,8 +154,8 @@ 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 Size) error {
- if offset.IsZero() || size == types.TombstoneFileSize {
+ err = idx.WalkIndexFile(idxFile, func(key types.NeedleId, offset types.Offset, size types.Size) error {
+ if offset.IsZero() || size < 0 || size == types.TombstoneFileSize {
files[key] = needleState{
state: stateDeleted,
size: size,