aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2022-06-10 06:38:17 -0700
committerchrislu <chris.lu@gmail.com>2022-06-10 06:38:17 -0700
commit9f8b72a54d8c97db5963f5204e2857e93bf22612 (patch)
treeb8126540c81be7c01b781df2a1408c81446a2259
parent873830a7bf37e6d1fcb2f03880f4e28fb279e91d (diff)
downloadseaweedfs-9f8b72a54d8c97db5963f5204e2857e93bf22612.tar.xz
seaweedfs-9f8b72a54d8c97db5963f5204e2857e93bf22612.zip
Revert "Merge pull request #3159 from shichanglin5/_duplicateUUID"
This reverts commit 37da68931941b1f084b7f4312722e4241e9ab0b0, reversing changes made to 00d53c34c44dd6442ec276f184344faa20c16db0.
-rw-r--r--weed/server/volume_grpc_client_to_master.go24
-rw-r--r--weed/storage/volume.go1
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
}