diff --git a/Makefile b/Makefile index 55c440a50..9916e574d 100644 --- a/Makefile +++ b/Makefile @@ -32,10 +32,7 @@ build-split: build-strbyteconv build-strbyteconv: @godep go test -race -coverprofile=cover.out github.com/minio-io/minio/pkgs/strbyteconv -build-storage: build-storage-append build-storage-encoded build-storage-fs - -build-storage-fs: - @godep go test -race -coverprofile=cover.out github.com/minio-io/minio/pkgs/storage/fsstorage +build-storage: build-storage-append build-storage-encoded build-storage-append: @godep go test -race -coverprofile=cover.out github.com/minio-io/minio/pkgs/storage/appendstorage diff --git a/cmd/erasure-demo/fs.go b/cmd/erasure-demo/fs.go deleted file mode 100644 index 8c1cf71b3..000000000 --- a/cmd/erasure-demo/fs.go +++ /dev/null @@ -1,53 +0,0 @@ -package main - -import ( - "bytes" - "encoding/json" - "io" - "os" - "path" - - "github.com/minio-io/minio/pkgs/storage" - "github.com/minio-io/minio/pkgs/storage/fsstorage" -) - -func fsGetList(config inputConfig) (io.Reader, error) { - var objectStorage storage.ObjectStorage - rootDir := path.Join(config.rootDir, config.storageDriver) - objectStorage, _ = fsstorage.NewStorage(rootDir, config.blockSize) - objectList, err := objectStorage.List() - if err != nil { - return nil, err - } - var objectListBytes []byte - if objectListBytes, err = json.Marshal(objectList); err != nil { - return nil, err - } - objectListBuffer := bytes.NewBuffer(objectListBytes) - return objectListBuffer, nil -} - -func fsGet(config inputConfig, objectPath string) (io.Reader, error) { - var objectStorage storage.ObjectStorage - rootDir := path.Join(config.rootDir, config.storageDriver) - objectStorage, _ = fsstorage.NewStorage(rootDir, config.blockSize) - object, err := objectStorage.Get(objectPath) - if err != nil { - return nil, err - } - return object, nil -} - -func fsPut(config inputConfig, objectPath string, reader io.Reader) error { - var err error - rootDir := path.Join(config.rootDir, config.storageDriver) - if err := os.MkdirAll(config.rootDir, 0700); err != nil { - return err - } - var objectStorage storage.ObjectStorage - objectStorage, _ = fsstorage.NewStorage(rootDir, config.blockSize) - if err = objectStorage.Put(objectPath, reader); err != nil { - return err - } - return nil -} diff --git a/cmd/erasure-demo/get.go b/cmd/erasure-demo/get.go index d95849733..0d96cae59 100644 --- a/cmd/erasure-demo/get.go +++ b/cmd/erasure-demo/get.go @@ -17,18 +17,6 @@ func get(c *cli.Context) { objectName := c.Args().Get(0) switch config.storageDriver { - case "fs": - { - if len(objectName) == 0 { - if objectReader, err = fsGetList(config); err != nil { - log.Fatal(err) - } - } else { - if objectReader, err = fsGet(config, objectName); err != nil { - log.Fatal(err) - } - } - } case "erasure": { if len(objectName) == 0 { diff --git a/cmd/erasure-demo/put.go b/cmd/erasure-demo/put.go index c025e1731..5e660a3d6 100644 --- a/cmd/erasure-demo/put.go +++ b/cmd/erasure-demo/put.go @@ -29,12 +29,6 @@ func put(c *cli.Context) { log.Fatal(err) } switch config.storageDriver { - case "fs": - { - if err := fsPut(config, objectName, inputFile); err != nil { - log.Fatal(err) - } - } case "erasure": { if err := erasurePut(config, objectName, inputFile); err != nil { diff --git a/pkgs/gateway/gateway.go b/pkgs/gateway/gateway.go index 5d53b7442..4e48c7195 100644 --- a/pkgs/gateway/gateway.go +++ b/pkgs/gateway/gateway.go @@ -26,7 +26,6 @@ import ( "github.com/gorilla/mux" "github.com/minio-io/minio/pkgs/storage/encodedstorage" - "github.com/minio-io/minio/pkgs/storage/fsstorage" "github.com/tchap/go-patricia/patricia" ) @@ -243,24 +242,24 @@ func SimpleEncodedStorageDriver(bucket string, input chan ObjectRequest, config } } -func SimpleFileStorageDriver(bucket string, input chan ObjectRequest, config GatewayConfig) { - fileStorage, _ := fsstorage.NewStorage(config.DataDir, config.BlockSize) - for request := range input { - switch request.requestType { - case "GET": - objectPath := path.Join(bucket, request.path) - object, err := fileStorage.Get(objectPath) - if err != nil { - request.callback <- nil - } else { - request.callback <- object - } - case "PUT": - objectPath := path.Join(bucket, request.path) - fileStorage.Put(objectPath, bytes.NewBuffer(request.object)) - request.callback <- nil - default: - request.callback <- errors.New("Unexpected message") - } - } -} +//func SimpleFileStorageDriver(bucket string, input chan ObjectRequest, config GatewayConfig) { +// fileStorage, _ := fsstorage.NewStorage(config.DataDir, config.BlockSize) +// for request := range input { +// switch request.requestType { +// case "GET": +// objectPath := path.Join(bucket, request.path) +// object, err := fileStorage.Get(objectPath) +// if err != nil { +// request.callback <- nil +// } else { +// request.callback <- object +// } +// case "PUT": +// objectPath := path.Join(bucket, request.path) +// fileStorage.Put(objectPath, bytes.NewBuffer(request.object)) +// request.callback <- nil +// default: +// request.callback <- errors.New("Unexpected message") +// } +// } +//} diff --git a/pkgs/gateway/gateway_test.go b/pkgs/gateway/gateway_test.go index ed9542cff..6e52389a0 100644 --- a/pkgs/gateway/gateway_test.go +++ b/pkgs/gateway/gateway_test.go @@ -116,11 +116,6 @@ func (s *GatewaySuite) TestInMemoryBucketOperations(c *C) { StorageDriver: InMemoryStorageDriver, requestBucketChan: make(chan BucketRequest), }, - GatewayConfig{ - StorageDriver: SimpleFileStorageDriver, - requestBucketChan: make(chan BucketRequest), - DataDir: simpleFileStorageRootDir, - }, GatewayConfig{ StorageDriver: SimpleEncodedStorageDriver, requestBucketChan: make(chan BucketRequest), diff --git a/pkgs/storage/fsstorage/Makefile b/pkgs/storage/fsstorage/Makefile deleted file mode 100644 index fb6ac1387..000000000 --- a/pkgs/storage/fsstorage/Makefile +++ /dev/null @@ -1,11 +0,0 @@ -all: build test -.PHONY: all - -build: - @godep go build - -test: build - @godep go test -race -coverprofile=cover.out - -clean: - @rm -v cover.out diff --git a/pkgs/storage/fsstorage/fs_storage.go b/pkgs/storage/fsstorage/fs_storage.go deleted file mode 100644 index c59d6606f..000000000 --- a/pkgs/storage/fsstorage/fs_storage.go +++ /dev/null @@ -1,177 +0,0 @@ -/* - * Mini Object Storage, (C) 2014 Minio, Inc. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package fsstorage - -import ( - "bytes" - "crypto/md5" - "encoding/gob" - "encoding/hex" - "errors" - "io" - "io/ioutil" - "os" - "path" - "strconv" - - "github.com/minio-io/minio/pkgs/split" - "github.com/minio-io/minio/pkgs/storage" - "github.com/minio-io/minio/pkgs/storage/appendstorage" - "github.com/spaolacci/murmur3" -) - -type fileSystemStorage struct { - RootDir string - BlockSize uint64 - diskStorage []storage.ObjectStorage - objects map[string]StorageEntry -} - -type StorageEntry struct { - Path string - Md5sum []byte - Murmurhash uint64 - ChunkLength int -} - -func NewStorage(rootDir string, blockSize uint64) (storage.ObjectStorage, error) { - var storageNodes []storage.ObjectStorage - storageNode, err := appendstorage.NewStorage(rootDir, 0) - if err != nil { - return nil, err - } - storageNodes = append(storageNodes, storageNode) - objects := make(map[string]StorageEntry) - indexPath := path.Join(rootDir, "index") - if _, err := os.Stat(indexPath); err == nil { - indexFile, err := os.Open(indexPath) - defer indexFile.Close() - if err != nil { - return nil, err - } - encoder := gob.NewDecoder(indexFile) - err = encoder.Decode(&objects) - if err != nil && err != io.EOF { - return nil, err - } - } - newStorage := fileSystemStorage{ - RootDir: rootDir, - diskStorage: storageNodes, - BlockSize: blockSize, - objects: objects, - } - return &newStorage, nil -} - -func (fsStorage *fileSystemStorage) List() ([]storage.ObjectDescription, error) { - var objectDescList []storage.ObjectDescription - for objectName, objectEntry := range fsStorage.objects { - var objectDescription storage.ObjectDescription - objectDescription.Name = objectName - objectDescription.Md5sum = hex.EncodeToString(objectEntry.Md5sum) - objectDescription.Murmur3 = strconv.FormatUint(objectEntry.Murmurhash, 16) - objectDescList = append(objectDescList, objectDescription) - } - if len(objectDescList) == 0 { - return nil, errors.New("No objects found") - } - return objectDescList, nil -} - -func (fsStorage *fileSystemStorage) Get(objectPath string) (io.Reader, error) { - entry, ok := fsStorage.objects[objectPath] - if ok == false { - return nil, nil - } - reader, writer := io.Pipe() - go fsStorage.readObject(objectPath, entry, writer) - return reader, nil -} - -func (fsStorage *fileSystemStorage) readObject(objectPath string, entry StorageEntry, writer *io.PipeWriter) { - appendStorage := fsStorage.diskStorage[0] - for i := 0; i < entry.ChunkLength; i++ { - chunkObjectPath := objectPath + "$" + strconv.Itoa(i) - chunkObject, err := appendStorage.Get(chunkObjectPath) - - if err != nil { - writer.CloseWithError(err) - } - data, readErr := ioutil.ReadAll(chunkObject) - - if readErr != nil { - writer.CloseWithError(readErr) - } - bytesWritten := 0 - for bytesWritten != len(data) { - written, err := writer.Write(data[bytesWritten:len(data)]) - if err != nil { - writer.CloseWithError(err) - } - bytesWritten += written - } - } - writer.Close() -} - -func (fsStorage *fileSystemStorage) Put(objectPath string, object io.Reader) error { - // split - chunks := make(chan split.SplitMessage) - go split.SplitStream(object, fsStorage.BlockSize, chunks) - - entry := StorageEntry{ - Path: objectPath, - Md5sum: nil, - Murmurhash: 0, - ChunkLength: 0, - } - - murmur := murmur3.Sum64([]byte(objectPath)) - hash := md5.New() - i := 0 - for chunk := range chunks { - if chunk.Err != nil { - return chunk.Err - } - err := fsStorage.storeBlocks(objectPath, i, chunk.Data) - if err != nil { - return err - } - // md5sum only after chunk is committed to disk - hash.Write(chunk.Data) - i++ - } - entry.Md5sum = hash.Sum(nil) - entry.ChunkLength = i - entry.Murmurhash = murmur - fsStorage.objects[objectPath] = entry - var gobBuffer bytes.Buffer - gobEncoder := gob.NewEncoder(&gobBuffer) - gobEncoder.Encode(fsStorage.objects) - ioutil.WriteFile(path.Join(fsStorage.RootDir, "index"), gobBuffer.Bytes(), 0600) - return nil -} - -func (fsStorage *fileSystemStorage) storeBlocks(objectPath string, index int, chunk []byte) error { - appendStorage := fsStorage.diskStorage[0] - path := objectPath + "$" + strconv.Itoa(index) - if err := appendStorage.Put(path, bytes.NewBuffer(chunk)); err != nil { - return err - } - return nil -} diff --git a/pkgs/storage/fsstorage/fs_storage_test.go b/pkgs/storage/fsstorage/fs_storage_test.go deleted file mode 100644 index fc582fd35..000000000 --- a/pkgs/storage/fsstorage/fs_storage_test.go +++ /dev/null @@ -1,44 +0,0 @@ -package fsstorage - -import ( - "bytes" - "io/ioutil" - "os" - "testing" - - "github.com/minio-io/minio/pkgs/storage" - "github.com/minio-io/minio/pkgs/utils" - . "gopkg.in/check.v1" -) - -type fileSystemStorageSuite struct{} - -var _ = Suite(&fileSystemStorageSuite{}) - -func Test(t *testing.T) { TestingT(t) } - -func (s *fileSystemStorageSuite) TestfileStoragePutAtRootPath(c *C) { - rootDir, err := utils.MakeTempTestDir() - c.Assert(err, IsNil) - defer os.RemoveAll(rootDir) - - var objectStorage storage.ObjectStorage - objectStorage, _ = NewStorage(rootDir, 1024) - - objectBuffer := bytes.NewBuffer([]byte("object1")) - err = objectStorage.Put("path1", objectBuffer) - c.Assert(err, IsNil) - - // assert object1 was created in correct path - objectResult1, err := objectStorage.Get("path1") - c.Assert(err, IsNil) - - object1, err := ioutil.ReadAll(objectResult1) - c.Assert(err, IsNil) - - c.Assert(string(object1), Equals, "object1") - - objectList, err := objectStorage.List() - c.Assert(err, IsNil) - c.Assert(objectList[0].Name, Equals, "path1") -}