|
|
@ -19,7 +19,6 @@ package server |
|
|
|
import ( |
|
|
|
import ( |
|
|
|
"log" |
|
|
|
"log" |
|
|
|
"os" |
|
|
|
"os" |
|
|
|
"os/user" |
|
|
|
|
|
|
|
"path" |
|
|
|
"path" |
|
|
|
"reflect" |
|
|
|
"reflect" |
|
|
|
|
|
|
|
|
|
|
@ -29,6 +28,7 @@ import ( |
|
|
|
mstorage "github.com/minio-io/minio/pkg/storage" |
|
|
|
mstorage "github.com/minio-io/minio/pkg/storage" |
|
|
|
"github.com/minio-io/minio/pkg/storage/fs" |
|
|
|
"github.com/minio-io/minio/pkg/storage/fs" |
|
|
|
"github.com/minio-io/minio/pkg/storage/inmemory" |
|
|
|
"github.com/minio-io/minio/pkg/storage/inmemory" |
|
|
|
|
|
|
|
"github.com/minio-io/minio/pkg/utils/helpers" |
|
|
|
) |
|
|
|
) |
|
|
|
|
|
|
|
|
|
|
|
type ServerConfig struct { |
|
|
|
type ServerConfig struct { |
|
|
@ -128,13 +128,9 @@ func getStorageChannels(storageType StorageType) (ctrlChans []chan<- string, sta |
|
|
|
} |
|
|
|
} |
|
|
|
case storageType == FileStorage: |
|
|
|
case storageType == FileStorage: |
|
|
|
{ |
|
|
|
{ |
|
|
|
// TODO Replace this with a more configurable and robust version
|
|
|
|
homeDir := helpers.HomeDir() |
|
|
|
currentUser, err := user.Current() |
|
|
|
rootPath := path.Join(homeDir, "minio-storage") |
|
|
|
if err != nil { |
|
|
|
_, err := os.Stat(rootPath) |
|
|
|
log.Fatal(err) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
rootPath := path.Join(currentUser.HomeDir, "minio-storage") |
|
|
|
|
|
|
|
_, err = os.Stat(rootPath) |
|
|
|
|
|
|
|
if os.IsNotExist(err) { |
|
|
|
if os.IsNotExist(err) { |
|
|
|
err = os.Mkdir(rootPath, 0700) |
|
|
|
err = os.Mkdir(rootPath, 0700) |
|
|
|
} else if err != nil { |
|
|
|
} else if err != nil { |
|
|
|