diff options
| author | Chris Lu <chrislusf@users.noreply.github.com> | 2022-07-20 09:06:06 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-07-20 09:06:06 -0700 |
| commit | 9ec0d1caaa1d7e7c9d19951aa0689eb47da8b8fa (patch) | |
| tree | 0aa52231e120c1b4033a0f64cd8fab742c7142ac /unmaintained/diff_volume_servers/diff_volume_servers.go | |
| parent | efec31de8df321b01c0e20085d0a10e430af2ed6 (diff) | |
| parent | ac694f0c8f2b5456bd175e1288023f0bdb5b7a14 (diff) | |
| download | seaweedfs-9ec0d1caaa1d7e7c9d19951aa0689eb47da8b8fa.tar.xz seaweedfs-9ec0d1caaa1d7e7c9d19951aa0689eb47da8b8fa.zip | |
Merge pull request #3337 from guol-fnst/loading_volume
Diffstat (limited to 'unmaintained/diff_volume_servers/diff_volume_servers.go')
| -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, |