diff options
| author | coffeecloudgit <168399738+coffeecloudgit@users.noreply.github.com> | 2024-09-28 03:04:27 +0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-09-27 12:04:27 -0700 |
| commit | dad3a26fb6a114e8b689ae60935e5f48d29cdd14 (patch) | |
| tree | 2d24a84db9633c401bda8a7309327c2843d90cc9 | |
| parent | bae93e611d8cc323d1040ed2bf2f0b7466d28bfc (diff) | |
| download | seaweedfs-dad3a26fb6a114e8b689ae60935e5f48d29cdd14.tar.xz seaweedfs-dad3a26fb6a114e8b689ae60935e5f48d29cdd14.zip | |
Update volume_grpc_erasure_coding.go , fix no space left bug (#6077)
| -rw-r--r-- | weed/server/volume_grpc_erasure_coding.go | 12 |
1 files changed, 4 insertions, 8 deletions
diff --git a/weed/server/volume_grpc_erasure_coding.go b/weed/server/volume_grpc_erasure_coding.go index f9c5ea683..fe12b3a22 100644 --- a/weed/server/volume_grpc_erasure_coding.go +++ b/weed/server/volume_grpc_erasure_coding.go @@ -150,8 +150,10 @@ func (vs *VolumeServer) VolumeEcShardsCopy(ctx context.Context, req *volume_serv }) } else { location = vs.store.FindFreeLocation(func(location *storage.DiskLocation) bool { - _, found := location.FindEcVolume(needle.VolumeId(req.VolumeId)) - return found + //(location.FindEcVolume) This method is error, will cause location is nil, redundant judgment + // _, found := location.FindEcVolume(needle.VolumeId(req.VolumeId)) + // return found + return true }) } if location == nil { @@ -191,12 +193,6 @@ func (vs *VolumeServer) VolumeEcShardsCopy(ctx context.Context, req *volume_serv return err } } - - if req.CopyEcxFile { //when location no volume before copy - glog.V(0).Infof("Re LoadNewVolumes: %v", req) - vs.store.LoadNewVolumes() - } - return nil }) if err != nil { |