aboutsummaryrefslogtreecommitdiff
path: root/go/filer
diff options
context:
space:
mode:
authorchrislusf <chris.lu@gmail.com>2015-03-10 00:20:31 -0700
committerchrislusf <chris.lu@gmail.com>2015-03-10 00:20:34 -0700
commitb07d81fb088638909ace217f4f2eb7927f094682 (patch)
tree3d01c017c05e82a78094fcbc5cf988a6cd6509d1 /go/filer
parentb4cb8bfd27687cb1bb95f63bc953d02116d02016 (diff)
downloadseaweedfs-b07d81fb088638909ace217f4f2eb7927f094682.tar.xz
seaweedfs-b07d81fb088638909ace217f4f2eb7927f094682.zip
follow golint suggestions
Diffstat (limited to 'go/filer')
-rw-r--r--go/filer/embedded_filer/directory_in_map.go6
-rw-r--r--go/filer/embedded_filer/filer_embedded.go10
-rw-r--r--go/filer/flat_namespace/flat_namespace_filer.go12
-rw-r--r--go/filer/redis_store/redis_store.go6
4 files changed, 16 insertions, 18 deletions
diff --git a/go/filer/embedded_filer/directory_in_map.go b/go/filer/embedded_filer/directory_in_map.go
index 1b904c874..148aae796 100644
--- a/go/filer/embedded_filer/directory_in_map.go
+++ b/go/filer/embedded_filer/directory_in_map.go
@@ -34,7 +34,7 @@ func (dm *DirectoryManagerInMap) NewDirectoryEntryInMap(parent *DirectoryEntryIn
writeLock.Lock()
defer writeLock.Unlock()
d = &DirectoryEntryInMap{Name: name, Parent: parent, SubDirectories: make(map[string]*DirectoryEntryInMap)}
- parts := make([]string, 0)
+ var parts []string
for p := d; p != nil && p.Name != ""; p = p.Parent {
parts = append(parts, p.Name)
}
@@ -162,7 +162,7 @@ func (dm *DirectoryManagerInMap) loadDirectory(dirPath string, dirId filer.Direc
sub, ok := dir.SubDirectories[parts[i]]
if !ok {
if i != len(parts)-1 {
- return fmt.Errorf("%s should be created after parent %s!", dirPath, parts[i])
+ return fmt.Errorf("%s should be created after parent %s", dirPath, parts[i])
}
var err error
sub, err = dm.NewDirectoryEntryInMap(dir, parts[i])
@@ -170,7 +170,7 @@ func (dm *DirectoryManagerInMap) loadDirectory(dirPath string, dirId filer.Direc
return err
}
if sub.Id != dirId {
- return fmt.Errorf("%s should be have id %v instead of %v!", dirPath, sub.Id, dirId)
+ return fmt.Errorf("%s should be have id %v instead of %v", dirPath, sub.Id, dirId)
}
dir.SubDirectories[parts[i]] = sub
}
diff --git a/go/filer/embedded_filer/filer_embedded.go b/go/filer/embedded_filer/filer_embedded.go
index 4321bb4e6..9c8012a6d 100644
--- a/go/filer/embedded_filer/filer_embedded.go
+++ b/go/filer/embedded_filer/filer_embedded.go
@@ -125,19 +125,17 @@ func (filer *FilerEmbedded) Move(fromPath string, toPath string) error {
if _, err := filer.FindDirectory(toPath); err == nil {
// move folder under an existing folder
return filer.directories.MoveUnderDirectory(fromPath, toPath, "")
- } else {
- // move folder to a new folder
- return filer.directories.MoveUnderDirectory(fromPath, filepath.Dir(toPath), filepath.Base(toPath))
}
+ // move folder to a new folder
+ return filer.directories.MoveUnderDirectory(fromPath, filepath.Dir(toPath), filepath.Base(toPath))
}
if fid, file_err := filer.DeleteFile(fromPath); file_err == nil {
if _, err := filer.FindDirectory(toPath); err == nil {
// move file under an existing folder
return filer.CreateFile(filepath.Join(toPath, filepath.Base(fromPath)), fid)
- } else {
- // move to a folder with new name
- return filer.CreateFile(toPath, fid)
}
+ // move to a folder with new name
+ return filer.CreateFile(toPath, fid)
}
return fmt.Errorf("File %s is not found!", fromPath)
}
diff --git a/go/filer/flat_namespace/flat_namespace_filer.go b/go/filer/flat_namespace/flat_namespace_filer.go
index 021b809d6..a0c484684 100644
--- a/go/filer/flat_namespace/flat_namespace_filer.go
+++ b/go/filer/flat_namespace/flat_namespace_filer.go
@@ -12,7 +12,7 @@ type FlatNamesapceFiler struct {
}
var (
- NotImplemented = errors.New("Not Implemented for flat namespace meta data store!")
+ ErrNotImplemented = errors.New("Not Implemented for flat namespace meta data store")
)
func NewFlatNamesapceFiler(master string, store FlatNamespaceStore) *FlatNamesapceFiler {
@@ -29,16 +29,16 @@ func (filer *FlatNamesapceFiler) FindFile(fullFileName string) (fid string, err
return filer.store.Get(fullFileName)
}
func (filer *FlatNamesapceFiler) FindDirectory(dirPath string) (dirId filer.DirectoryId, err error) {
- return 0, NotImplemented
+ return 0, ErrNotImplemented
}
func (filer *FlatNamesapceFiler) ListDirectories(dirPath string) (dirs []filer.DirectoryEntry, err error) {
- return nil, NotImplemented
+ return nil, ErrNotImplemented
}
func (filer *FlatNamesapceFiler) ListFiles(dirPath string, lastFileName string, limit int) (files []filer.FileEntry, err error) {
- return nil, NotImplemented
+ return nil, ErrNotImplemented
}
func (filer *FlatNamesapceFiler) DeleteDirectory(dirPath string, recursive bool) (err error) {
- return NotImplemented
+ return ErrNotImplemented
}
func (filer *FlatNamesapceFiler) DeleteFile(fullFileName string) (fid string, err error) {
@@ -46,5 +46,5 @@ func (filer *FlatNamesapceFiler) DeleteFile(fullFileName string) (fid string, er
}
func (filer *FlatNamesapceFiler) Move(fromPath string, toPath string) error {
- return NotImplemented
+ return ErrNotImplemented
}
diff --git a/go/filer/redis_store/redis_store.go b/go/filer/redis_store/redis_store.go
index 8fe1c7ca5..e71776845 100644
--- a/go/filer/redis_store/redis_store.go
+++ b/go/filer/redis_store/redis_store.go
@@ -41,8 +41,8 @@ func (s *RedisStore) Delete(fullFileName string) (fid string, err error) {
return "", err
}
-func (c *RedisStore) Close() {
- if c.Client != nil {
- c.Client.Close()
+func (s *RedisStore) Close() {
+ if s.Client != nil {
+ s.Client.Close()
}
}