From 9f8b72a54d8c97db5963f5204e2857e93bf22612 Mon Sep 17 00:00:00 2001 From: chrislu Date: Fri, 10 Jun 2022 06:38:17 -0700 Subject: [PATCH] Revert "Merge pull request #3159 from shichanglin5/_duplicateUUID" This reverts commit 37da68931941b1f084b7f4312722e4241e9ab0b0, reversing changes made to 00d53c34c44dd6442ec276f184344faa20c16db0. --- weed/server/volume_grpc_client_to_master.go | 24 +++++---------------- weed/storage/volume.go | 1 + 2 files changed, 6 insertions(+), 19 deletions(-) diff --git a/weed/server/volume_grpc_client_to_master.go b/weed/server/volume_grpc_client_to_master.go index a7b75d6a5..d4f3b2853 100644 --- a/weed/server/volume_grpc_client_to_master.go +++ b/weed/server/volume_grpc_client_to_master.go @@ -119,30 +119,16 @@ func (vs *VolumeServer) doHeartbeat(masterAddress pb.ServerAddress, grpcDialOpti return } if len(in.DuplicatedUuids) > 0 { - var duplicatedDir []string - - foundDuplicate := false - duplicateSet := make(map[string]struct{}) + var duplictedDir []string for _, loc := range vs.store.Locations { - directoryUuid := loc.DirectoryUuid - if _, exists := duplicateSet[directoryUuid]; !exists { - duplicateSet[directoryUuid] = struct{}{} - } else { - foundDuplicate = true - } - for _, uuid := range in.DuplicatedUuids { - if uuid == directoryUuid { - duplicatedDir = append(duplicatedDir, loc.Directory) + if uuid == loc.DirectoryUuid { + duplictedDir = append(duplictedDir, loc.Directory) } } } - if foundDuplicate { - glog.Errorf("Shut down Volume Server due to duplicated volume directories: %v", duplicatedDir) - os.Exit(1) - } else { - glog.Warningf("Receive response of duplicated volume directories: %v, ignored(the check found no duplicates)", duplicatedDir) - } + glog.Errorf("Shut down Volume Server due to duplicated volume directories: %v", duplictedDir) + os.Exit(1) } if in.GetVolumeSizeLimit() != 0 && vs.store.GetVolumeSizeLimit() != in.GetVolumeSizeLimit() { vs.store.SetVolumeSizeLimit(in.GetVolumeSizeLimit()) diff --git a/weed/storage/volume.go b/weed/storage/volume.go index fc77fa63a..3539efa85 100644 --- a/weed/storage/volume.go +++ b/weed/storage/volume.go @@ -293,6 +293,7 @@ func (v *Volume) collectStatus() (maxFileKey types.NeedleId, datFileSize int64, fileCount = uint64(v.nm.FileCount()) deletedCount = uint64(v.nm.DeletedCount()) deletedSize = v.nm.DeletedSize() + fileCount = uint64(v.nm.FileCount()) return }