|
@@ -4,7 +4,6 @@ import (
|
|
"encoding/json"
|
|
"encoding/json"
|
|
"errors"
|
|
"errors"
|
|
"io/ioutil"
|
|
"io/ioutil"
|
|
- "log"
|
|
|
|
"net/http"
|
|
"net/http"
|
|
"os"
|
|
"os"
|
|
"path/filepath"
|
|
"path/filepath"
|
|
@@ -94,7 +93,7 @@ func HandleFSHEdit(w http.ResponseWriter, r *http.Request) {
|
|
common.SendErrorResponse(w, err.Error())
|
|
common.SendErrorResponse(w, err.Error())
|
|
return
|
|
return
|
|
}
|
|
}
|
|
- log.Println(newFsOption)
|
|
|
|
|
|
+ //systemWideLogger.PrintAndLog("Storage", newFsOption, nil)
|
|
|
|
|
|
uuid := newFsOption.Uuid
|
|
uuid := newFsOption.Uuid
|
|
|
|
|
|
@@ -142,7 +141,7 @@ func HandleFSHEdit(w http.ResponseWriter, r *http.Request) {
|
|
originalConfigFile, _ := ioutil.ReadFile(configFile)
|
|
originalConfigFile, _ := ioutil.ReadFile(configFile)
|
|
err := json.Unmarshal(originalConfigFile, &oldConfigs)
|
|
err := json.Unmarshal(originalConfigFile, &oldConfigs)
|
|
if err != nil {
|
|
if err != nil {
|
|
- log.Println(err)
|
|
|
|
|
|
+ systemWideLogger.PrintAndLog("Storage", err.Error(), err)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
@@ -175,7 +174,7 @@ func getFSHConfigFromGroupAndUUID(group string, uuid string) (*fs.FileSystemOpti
|
|
|
|
|
|
//Check if file exists.
|
|
//Check if file exists.
|
|
if !fs.FileExists(targerFile) {
|
|
if !fs.FileExists(targerFile) {
|
|
- log.Println("Config file not found: ", targerFile)
|
|
|
|
|
|
+ systemWideLogger.PrintAndLog("Storage", "Config file not found: "+targerFile, nil)
|
|
return nil, errors.New("Configuration file not found")
|
|
return nil, errors.New("Configuration file not found")
|
|
}
|
|
}
|
|
|
|
|
|
@@ -192,7 +191,7 @@ func getFSHConfigFromGroupAndUUID(group string, uuid string) (*fs.FileSystemOpti
|
|
loadedConfig := []fs.FileSystemOption{}
|
|
loadedConfig := []fs.FileSystemOption{}
|
|
err = json.Unmarshal(configContent, &loadedConfig)
|
|
err = json.Unmarshal(configContent, &loadedConfig)
|
|
if err != nil {
|
|
if err != nil {
|
|
- log.Println("Request to parse config error: "+err.Error(), targerFile)
|
|
|
|
|
|
+ systemWideLogger.PrintAndLog("Storage", "Request to parse config error: "+err.Error()+targerFile, err)
|
|
return nil, err
|
|
return nil, err
|
|
}
|
|
}
|
|
|
|
|
|
@@ -218,7 +217,7 @@ func setFSHConfigByGroupAndId(group string, uuid string, options fs.FileSystemOp
|
|
|
|
|
|
//Check if file exists.
|
|
//Check if file exists.
|
|
if !fs.FileExists(targerFile) {
|
|
if !fs.FileExists(targerFile) {
|
|
- log.Println("Config file not found: ", targerFile)
|
|
|
|
|
|
+ systemWideLogger.PrintAndLog("Storage", "Config file not found: "+targerFile, nil)
|
|
return errors.New("Configuration file not found")
|
|
return errors.New("Configuration file not found")
|
|
}
|
|
}
|
|
|
|
|
|
@@ -235,7 +234,7 @@ func setFSHConfigByGroupAndId(group string, uuid string, options fs.FileSystemOp
|
|
loadedConfig := []fs.FileSystemOption{}
|
|
loadedConfig := []fs.FileSystemOption{}
|
|
err = json.Unmarshal(configContent, &loadedConfig)
|
|
err = json.Unmarshal(configContent, &loadedConfig)
|
|
if err != nil {
|
|
if err != nil {
|
|
- log.Println("Request to parse config error: "+err.Error(), targerFile)
|
|
|
|
|
|
+ systemWideLogger.PrintAndLog("Storage", "Request to parse config error: "+err.Error()+targerFile, err)
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
|
|
|
|
@@ -355,7 +354,7 @@ func HandleStoragePoolReload(w http.ResponseWriter, r *http.Request) {
|
|
//Start BasePool again
|
|
//Start BasePool again
|
|
err := LoadBaseStoragePool()
|
|
err := LoadBaseStoragePool()
|
|
if err != nil {
|
|
if err != nil {
|
|
- log.Println(err.Error())
|
|
|
|
|
|
+ systemWideLogger.PrintAndLog("Storage", err.Error(), err)
|
|
} else {
|
|
} else {
|
|
//Update userHandler's basePool
|
|
//Update userHandler's basePool
|
|
userHandler.UpdateStoragePool(baseStoragePool)
|
|
userHandler.UpdateStoragePool(baseStoragePool)
|
|
@@ -363,7 +362,7 @@ func HandleStoragePoolReload(w http.ResponseWriter, r *http.Request) {
|
|
|
|
|
|
//Reload all permission group's pool
|
|
//Reload all permission group's pool
|
|
for _, pg := range permissionHandler.PermissionGroups {
|
|
for _, pg := range permissionHandler.PermissionGroups {
|
|
- log.Println("Reloading Storage Pool for: " + pg.Name)
|
|
|
|
|
|
+ systemWideLogger.PrintAndLog("Storage", "Reloading Storage Pool for: "+pg.Name, err)
|
|
|
|
|
|
//Pool should be exists. Close it
|
|
//Pool should be exists. Close it
|
|
pg.StoragePool.Close()
|
|
pg.StoragePool.Close()
|
|
@@ -390,7 +389,7 @@ func HandleStoragePoolReload(w http.ResponseWriter, r *http.Request) {
|
|
//Start BasePool again
|
|
//Start BasePool again
|
|
err := LoadBaseStoragePool()
|
|
err := LoadBaseStoragePool()
|
|
if err != nil {
|
|
if err != nil {
|
|
- log.Println(err.Error())
|
|
|
|
|
|
+ systemWideLogger.PrintAndLog("Storage", err.Error(), err)
|
|
} else {
|
|
} else {
|
|
//Update userHandler's basePool
|
|
//Update userHandler's basePool
|
|
userHandler.UpdateStoragePool(baseStoragePool)
|
|
userHandler.UpdateStoragePool(baseStoragePool)
|
|
@@ -405,7 +404,7 @@ func HandleStoragePoolReload(w http.ResponseWriter, r *http.Request) {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
- log.Println("Reloading Storage Pool for: " + pool)
|
|
|
|
|
|
+ systemWideLogger.PrintAndLog("Storage", "Reloading Storage Pool for: "+pool, nil)
|
|
|
|
|
|
//Pool should be exists. Close it
|
|
//Pool should be exists. Close it
|
|
pg := permissionHandler.GetPermissionGroupByName(pool)
|
|
pg := permissionHandler.GetPermissionGroupByName(pool)
|
|
@@ -568,7 +567,7 @@ func HandleStorageNewFsHandler(w http.ResponseWriter, r *http.Request) {
|
|
originalConfigFile, _ := ioutil.ReadFile(configFile)
|
|
originalConfigFile, _ := ioutil.ReadFile(configFile)
|
|
err := json.Unmarshal(originalConfigFile, &oldConfigs)
|
|
err := json.Unmarshal(originalConfigFile, &oldConfigs)
|
|
if err != nil {
|
|
if err != nil {
|
|
- log.Println(err)
|
|
|
|
|
|
+ systemWideLogger.PrintAndLog(err,nil)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
@@ -667,7 +666,7 @@ func HandleFSHBridging(w http.ResponseWriter, r *http.Request) {
|
|
//Add the target FSH into the base pool
|
|
//Add the target FSH into the base pool
|
|
basePoolObject, err := GetStoragePoolByOwner(basePool)
|
|
basePoolObject, err := GetStoragePoolByOwner(basePool)
|
|
if err != nil {
|
|
if err != nil {
|
|
- log.Println("Bridge FSH failed: ", err.Error())
|
|
|
|
|
|
+ systemWideLogger.PrintAndLog("Storage", "Bridge FSH failed: "+err.Error(), err)
|
|
common.SendErrorResponse(w, "Storage pool not found")
|
|
common.SendErrorResponse(w, "Storage pool not found")
|
|
return
|
|
return
|
|
}
|
|
}
|