diff options
| author | guol-fnst <guol-fnst@fujitsu.com> | 2022-07-20 09:26:06 +0800 |
|---|---|---|
| committer | guol-fnst <guol-fnst@fujitsu.com> | 2022-07-20 17:00:40 +0800 |
| commit | ac694f0c8f2b5456bd175e1288023f0bdb5b7a14 (patch) | |
| tree | cfe997c93e69b35fe892fec44777b8c342ec405f /unmaintained/diff_volume_servers | |
| parent | 91285bb51d3b95befb5aba0104f6ac83e5b07572 (diff) | |
| download | seaweedfs-ac694f0c8f2b5456bd175e1288023f0bdb5b7a14.tar.xz seaweedfs-ac694f0c8f2b5456bd175e1288023f0bdb5b7a14.zip | |
rename parameter and reuse functions
rename milestone to watermark
Diffstat (limited to 'unmaintained/diff_volume_servers')
| -rw-r--r-- | unmaintained/diff_volume_servers/diff_volume_servers.go | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/unmaintained/diff_volume_servers/diff_volume_servers.go b/unmaintained/diff_volume_servers/diff_volume_servers.go index 0188d18d4..815eeae54 100644 --- a/unmaintained/diff_volume_servers/diff_volume_servers.go +++ b/unmaintained/diff_volume_servers/diff_volume_servers.go @@ -6,6 +6,10 @@ import ( "errors" "flag" "fmt" + "io" + "math" + "os" + "github.com/chrislusf/seaweedfs/weed/glog" "github.com/chrislusf/seaweedfs/weed/operation" "github.com/chrislusf/seaweedfs/weed/pb" @@ -16,9 +20,6 @@ import ( "github.com/chrislusf/seaweedfs/weed/storage/types" "github.com/chrislusf/seaweedfs/weed/util" "google.golang.org/grpc" - "io" - "math" - "os" ) var ( @@ -155,7 +156,7 @@ func getVolumeFiles(v uint32, addr pb.ServerAddress) (map[types.NeedleId]needleS var maxOffset int64 files := map[types.NeedleId]needleState{} - err = idx.WalkIndexFile(idxFile, func(key types.NeedleId, offset types.Offset, size types.Size) error { + err = idx.WalkIndexFile(idxFile, 0, func(key types.NeedleId, offset types.Offset, size types.Size) error { if offset.IsZero() || size.IsDeleted() { files[key] = needleState{ state: stateDeleted, |