Revert "Merge pull request #3159 from shichanglin5/_duplicateUUID"

This reverts commit 37da689319, reversing
changes made to 00d53c34c4.
This commit is contained in:
chrislu 2022-06-10 06:38:17 -07:00
parent 873830a7bf
commit 9f8b72a54d
2 changed files with 6 additions and 19 deletions

View file

@ -119,30 +119,16 @@ func (vs *VolumeServer) doHeartbeat(masterAddress pb.ServerAddress, grpcDialOpti
return return
} }
if len(in.DuplicatedUuids) > 0 { if len(in.DuplicatedUuids) > 0 {
var duplicatedDir []string var duplictedDir []string
foundDuplicate := false
duplicateSet := make(map[string]struct{})
for _, loc := range vs.store.Locations { 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 { for _, uuid := range in.DuplicatedUuids {
if uuid == directoryUuid { if uuid == loc.DirectoryUuid {
duplicatedDir = append(duplicatedDir, loc.Directory) duplictedDir = append(duplictedDir, loc.Directory)
} }
} }
} }
if foundDuplicate { glog.Errorf("Shut down Volume Server due to duplicated volume directories: %v", duplictedDir)
glog.Errorf("Shut down Volume Server due to duplicated volume directories: %v", duplicatedDir) os.Exit(1)
os.Exit(1)
} else {
glog.Warningf("Receive response of duplicated volume directories: %v, ignored(the check found no duplicates)", duplicatedDir)
}
} }
if in.GetVolumeSizeLimit() != 0 && vs.store.GetVolumeSizeLimit() != in.GetVolumeSizeLimit() { if in.GetVolumeSizeLimit() != 0 && vs.store.GetVolumeSizeLimit() != in.GetVolumeSizeLimit() {
vs.store.SetVolumeSizeLimit(in.GetVolumeSizeLimit()) vs.store.SetVolumeSizeLimit(in.GetVolumeSizeLimit())

View file

@ -293,6 +293,7 @@ func (v *Volume) collectStatus() (maxFileKey types.NeedleId, datFileSize int64,
fileCount = uint64(v.nm.FileCount()) fileCount = uint64(v.nm.FileCount())
deletedCount = uint64(v.nm.DeletedCount()) deletedCount = uint64(v.nm.DeletedCount())
deletedSize = v.nm.DeletedSize() deletedSize = v.nm.DeletedSize()
fileCount = uint64(v.nm.FileCount())
return return
} }