mirror of
https://github.com/minio/minio.git
synced 2025-02-03 01:46:00 -05:00
Merge pull request #364 from fkautz/pr_out_using_iodine_in_donut_start_
This commit is contained in:
commit
12a17f1ed7
@ -24,8 +24,10 @@ import (
|
|||||||
"strings"
|
"strings"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
|
"github.com/minio-io/iodine"
|
||||||
"github.com/minio-io/minio/pkg/drivers"
|
"github.com/minio-io/minio/pkg/drivers"
|
||||||
"github.com/minio-io/minio/pkg/storage/donut"
|
"github.com/minio-io/minio/pkg/storage/donut"
|
||||||
|
"log"
|
||||||
)
|
)
|
||||||
|
|
||||||
// donutDriver - creates a new single disk drivers driver using donut
|
// donutDriver - creates a new single disk drivers driver using donut
|
||||||
@ -44,7 +46,11 @@ func Start(path string) (chan<- string, <-chan error, drivers.Driver) {
|
|||||||
s := new(donutDriver)
|
s := new(donutDriver)
|
||||||
|
|
||||||
// TODO donut driver should be passed in as Start param and driven by config
|
// TODO donut driver should be passed in as Start param and driven by config
|
||||||
s.donut, _ = donut.NewDonut(path)
|
var err *iodine.Error
|
||||||
|
s.donut, err = donut.NewDonut(path)
|
||||||
|
if err != nil {
|
||||||
|
log.Println(err.EmitHumanReadable())
|
||||||
|
}
|
||||||
|
|
||||||
go start(ctrlChannel, errorChannel, s)
|
go start(ctrlChannel, errorChannel, s)
|
||||||
return ctrlChannel, errorChannel, s
|
return ctrlChannel, errorChannel, s
|
||||||
|
Loading…
x
Reference in New Issue
Block a user