Merge pull request #653 from harshavardhana/pr_out_hold_lock_on_getglobalstatekey_fixes_652

Hold lock on GetGlobalStateKey() - fixes #652
master
Harshavardhana 9 years ago
commit 3842a57f52
  1. 2
      pkg/iodine/iodine.go
  2. 2
      pkg/storage/drivers/fs/fs_bucket.go
  3. 2
      pkg/storage/drivers/fs/fs_filter.go

@ -87,7 +87,9 @@ func GetGlobalState() map[string]string {
// GetGlobalStateKey - get value for key from globalState struct
func GetGlobalStateKey(k string) string {
globalState.RLock()
result, ok := globalState.m[k]
globalState.RUnlock()
if !ok {
return ""
}

@ -192,7 +192,7 @@ func (fs *fsDriver) ListObjects(bucket string, resources drivers.BucketResources
break
}
if name > resources.Marker {
metadata, resources, err = fs.filter(bucket, name, p.files[name], resources)
metadata, resources, err = fs.filterObjects(bucket, name, p.files[name], resources)
if err != nil {
return []drivers.ObjectMetadata{}, resources, iodine.New(err, nil)
}

@ -24,7 +24,7 @@ import (
"github.com/minio/minio/pkg/storage/drivers"
)
func (fs *fsDriver) filter(bucket, name string, file os.FileInfo, resources drivers.BucketResourcesMetadata) (drivers.ObjectMetadata, drivers.BucketResourcesMetadata, error) {
func (fs *fsDriver) filterObjects(bucket, name string, file os.FileInfo, resources drivers.BucketResourcesMetadata) (drivers.ObjectMetadata, drivers.BucketResourcesMetadata, error) {
var err error
var metadata drivers.ObjectMetadata

Loading…
Cancel
Save