|
@ -58,6 +58,9 @@ func LoadConfiguration(config *util.ViperProxy) { |
|
|
if !config.GetBool(StorageBackendPrefix + "." + backendTypeName + "." + backendStorageId + ".enabled") { |
|
|
if !config.GetBool(StorageBackendPrefix + "." + backendTypeName + "." + backendStorageId + ".enabled") { |
|
|
continue |
|
|
continue |
|
|
} |
|
|
} |
|
|
|
|
|
if _, found := BackendStorages[backendTypeName+"."+backendStorageId]; found { |
|
|
|
|
|
continue |
|
|
|
|
|
} |
|
|
backendStorage, buildErr := backendStorageFactory.BuildStorage(config, |
|
|
backendStorage, buildErr := backendStorageFactory.BuildStorage(config, |
|
|
StorageBackendPrefix+"."+backendTypeName+"."+backendStorageId+".", backendStorageId) |
|
|
StorageBackendPrefix+"."+backendTypeName+"."+backendStorageId+".", backendStorageId) |
|
|
if buildErr != nil { |
|
|
if buildErr != nil { |
|
@ -81,6 +84,9 @@ func LoadFromPbStorageBackends(storageBackends []*master_pb.StorageBackend) { |
|
|
glog.Warningf("storage type %s not found", storageBackend.Type) |
|
|
glog.Warningf("storage type %s not found", storageBackend.Type) |
|
|
continue |
|
|
continue |
|
|
} |
|
|
} |
|
|
|
|
|
if _, found := BackendStorages[storageBackend.Type+"."+storageBackend.Id]; found { |
|
|
|
|
|
continue |
|
|
|
|
|
} |
|
|
backendStorage, buildErr := backendStorageFactory.BuildStorage(newProperties(storageBackend.Properties), "", storageBackend.Id) |
|
|
backendStorage, buildErr := backendStorageFactory.BuildStorage(newProperties(storageBackend.Properties), "", storageBackend.Id) |
|
|
if buildErr != nil { |
|
|
if buildErr != nil { |
|
|
glog.Fatalf("fail to create backend storage %s.%s", storageBackend.Type, storageBackend.Id) |
|
|
glog.Fatalf("fail to create backend storage %s.%s", storageBackend.Type, storageBackend.Id) |
|
|