From b32e371420fff5763c13c79cd4327692e2a2e1bd Mon Sep 17 00:00:00 2001 From: radhika Date: Thu, 21 Jan 2016 15:25:06 -0500 Subject: [PATCH] 8178: All three currently supported volumes return error when trash-lifetime period is not configured. azure blob and s3 volumes are updated to do so. Returning an error is causing test failures in unix volume and hence is still a work in progress. --- services/keepstore/azure_blob_volume.go | 5 +++++ services/keepstore/keepstore_test.go | 2 ++ services/keepstore/s3_volume.go | 4 ++++ services/keepstore/volume_unix.go | 4 ++++ 4 files changed, 15 insertions(+) diff --git a/services/keepstore/azure_blob_volume.go b/services/keepstore/azure_blob_volume.go index 0071567afa..f135835074 100644 --- a/services/keepstore/azure_blob_volume.go +++ b/services/keepstore/azure_blob_volume.go @@ -43,6 +43,11 @@ type azureVolumeAdder struct { } func (s *azureVolumeAdder) Set(containerName string) error { + if trashLifetime <= 0 { + log.Print("Missing required configuration parameter: trash-lifetime") + return ErrNotImplemented + } + if containerName == "" { return errors.New("no container name given") } diff --git a/services/keepstore/keepstore_test.go b/services/keepstore/keepstore_test.go index 2a1c3d243a..746d99efd0 100644 --- a/services/keepstore/keepstore_test.go +++ b/services/keepstore/keepstore_test.go @@ -335,6 +335,7 @@ func TestDiscoverTmpfs(t *testing.T) { f.Close() ProcMounts = f.Name() + trashLifetime = 24 * 60 * 60 resultVols := volumeSet{} added := (&unixVolumeAdder{&resultVols}).Discover() @@ -375,6 +376,7 @@ func TestDiscoverNone(t *testing.T) { f.Close() ProcMounts = f.Name() + trashLifetime = 24 * 60 * 60 resultVols := volumeSet{} added := (&unixVolumeAdder{&resultVols}).Discover() if added != 0 || len(resultVols) != 0 { diff --git a/services/keepstore/s3_volume.go b/services/keepstore/s3_volume.go index 16afc326b5..17cc194a5b 100644 --- a/services/keepstore/s3_volume.go +++ b/services/keepstore/s3_volume.go @@ -39,6 +39,10 @@ type s3VolumeAdder struct { } func (s *s3VolumeAdder) Set(bucketName string) error { + if trashLifetime <= 0 { + log.Print("Missing required configuration parameter: trash-lifetime") + return ErrNotImplemented + } if bucketName == "" { return fmt.Errorf("no container name given") } diff --git a/services/keepstore/volume_unix.go b/services/keepstore/volume_unix.go index da1d390279..1be622c23f 100644 --- a/services/keepstore/volume_unix.go +++ b/services/keepstore/volume_unix.go @@ -23,6 +23,10 @@ type unixVolumeAdder struct { } func (vs *unixVolumeAdder) Set(value string) error { + if trashLifetime <= 0 { + log.Print("Missing required configuration parameter: trash-lifetime") + //return ErrNotImplemented + } if dirs := strings.Split(value, ","); len(dirs) > 1 { log.Print("DEPRECATED: using comma-separated volume list.") for _, dir := range dirs { -- 2.30.2