diff options
| author | guol-fnst <guol-fnst@fujitsu.com> | 2022-07-19 13:17:52 +0800 |
|---|---|---|
| committer | guol-fnst <guol-fnst@fujitsu.com> | 2022-07-19 16:58:53 +0800 |
| commit | b9256e0b34fcd8ae62b89d1df5b61b7c35e204b4 (patch) | |
| tree | 3b7e2c374022b547a12568be4a184b460334daa1 /weed/storage/disk_location.go | |
| parent | bec9f79659297ae7f64db40c5d9ed10396de7ea7 (diff) | |
| download | seaweedfs-b9256e0b34fcd8ae62b89d1df5b61b7c35e204b4.tar.xz seaweedfs-b9256e0b34fcd8ae62b89d1df5b61b7c35e204b4.zip | |
optimiz
Diffstat (limited to 'weed/storage/disk_location.go')
| -rw-r--r-- | weed/storage/disk_location.go | 7 |
1 files changed, 2 insertions, 5 deletions
diff --git a/weed/storage/disk_location.go b/weed/storage/disk_location.go index d72d83208..8af8ea663 100644 --- a/weed/storage/disk_location.go +++ b/weed/storage/disk_location.go @@ -123,7 +123,7 @@ func (l *DiskLocation) loadExistingVolume(dirEntry os.DirEntry, needleMapKind Ne if volumeName == "" { return false } - glog.V(0).Infof("data file %s", l.Directory+"/"+volumeName) + // skip if ec volumes exists if skipIfEcVolumesExists { if util.FileExists(l.Directory + "/" + volumeName + ".ecx") { @@ -147,7 +147,7 @@ func (l *DiskLocation) loadExistingVolume(dirEntry os.DirEntry, needleMapKind Ne glog.Warningf("get volume id failed, %s, err : %s", volumeName, err) return false } - glog.V(0).Infof("data file %s", l.Directory+"/"+volumeName) + // avoid loading one volume more than once l.volumesLock.RLock() _, found := l.volumes[vid] @@ -156,7 +156,6 @@ func (l *DiskLocation) loadExistingVolume(dirEntry os.DirEntry, needleMapKind Ne glog.V(1).Infof("loaded volume, %v", vid) return true } - glog.V(0).Infof("data file %s", l.Directory+"/"+volumeName) // load the volume v, e := NewVolume(l.Directory, l.IdxDirectory, collection, vid, needleMapKind, nil, nil, 0, 0) @@ -223,8 +222,6 @@ func (l *DiskLocation) loadExistingVolumes(needleMapKind NeedleMapKind) { workerNum = 10 } } - workerNum = 10 - l.concurrentLoadingVolumes(needleMapKind, workerNum) glog.V(0).Infof("Store started on dir: %s with %d volumes max %d", l.Directory, len(l.volumes), l.MaxVolumeCount) |