lsm/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2025-04-05 20:52:50 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Update volume_grpc_erasure_coding.go , fix no space left bug (#6077)
Some checks failed
go: build dev binaries / cleanup (push) Has been cancelled
Details
docker: build dev containers / build-dev-containers (push) Has been cancelled
Details
End to End / FUSE Mount (push) Has been cancelled
Details
go: build binary / Build (push) Has been cancelled
Details
Ceph S3 tests / Ceph S3 tests (push) Has been cancelled
Details
go: build dev binaries / build_dev_linux_windows (amd64, linux) (push) Has been cancelled
Details
go: build dev binaries / build_dev_linux_windows (amd64, windows) (push) Has been cancelled
Details
go: build dev binaries / build_dev_darwin (amd64, darwin) (push) Has been cancelled
Details
go: build dev binaries / build_dev_darwin (arm64, darwin) (push) Has been cancelled
Details

Browse Source
This commit is contained in:
coffeecloudgit 2024-09-28 03:04:27 +08:00 committed by GitHub
parent bae93e611d
commit dad3a26fb6
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 4 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
weed/server/volume_grpc_erasure_coding.go
View File

@ -150,8 +150,10 @@ func (vs *VolumeServer) VolumeEcShardsCopy(ctx context.Context, req *volume_serv
}) })
} else { } else {
location = vs.store.FindFreeLocation(func(location *storage.DiskLocation) bool { location = vs.store.FindFreeLocation(func(location *storage.DiskLocation) bool {
_, found := location.FindEcVolume(needle.VolumeId(req.VolumeId)) //(location.FindEcVolume) This method is error, will cause location is nil, redundant judgment
return found // _, found := location.FindEcVolume(needle.VolumeId(req.VolumeId))
// return found
return true
}) })
} }
if location == nil { if location == nil {
@ -191,12 +193,6 @@ func (vs *VolumeServer) VolumeEcShardsCopy(ctx context.Context, req *volume_serv
return err return err
} }
} }
if req.CopyEcxFile { //when location no volume before copy
glog.V(0).Infof("Re LoadNewVolumes: %v", req)
vs.store.LoadNewVolumes()
}
return nil return nil
}) })
if err != nil { if err != nil {