aboutsummaryrefslogtreecommitdiff
path: root/weed
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-04-12 03:11:19 -0700
committerChris Lu <chris.lu@gmail.com>2020-04-12 03:11:19 -0700
commit1c2e920fa2831d871ec55fed04818fddaaaacbd5 (patch)
tree061264920d56c197b55cac93985662f2ad33773e /weed
parentb5a713be6843d8899cfae1021ac54a18b9315dd2 (diff)
downloadseaweedfs-1c2e920fa2831d871ec55fed04818fddaaaacbd5.tar.xz
seaweedfs-1c2e920fa2831d871ec55fed04818fddaaaacbd5.zip
fix compilation error
Diffstat (limited to 'weed')
-rw-r--r--weed/filer2/redis2/universal_redis_store.go7
1 files changed, 2 insertions, 5 deletions
diff --git a/weed/filer2/redis2/universal_redis_store.go b/weed/filer2/redis2/universal_redis_store.go
index 457ab50c6..420336b46 100644
--- a/weed/filer2/redis2/universal_redis_store.go
+++ b/weed/filer2/redis2/universal_redis_store.go
@@ -38,16 +38,13 @@ func (store *UniversalRedis2Store) InsertEntry(ctx context.Context, entry *filer
return fmt.Errorf("encoding %s %+v: %v", entry.FullPath, entry.Attr, err)
}
- _, err = store.Client.Set(string(entry.FullPath), value, time.Duration(entry.TtlSec)*time.Second).Result()
-
- if err != nil {
+ if err = store.Client.Set(string(entry.FullPath), value, time.Duration(entry.TtlSec)*time.Second).Err(); err != nil {
return fmt.Errorf("persisting %s : %v", entry.FullPath, err)
}
dir, name := entry.FullPath.DirAndName()
if name != "" {
- _, err = store.Client.ZAdd(genDirectoryListKey(dir), &redis.Z{Score: 0, Member: name}).Result()
- if err != nil {
+ if err = store.Client.ZAddNX(genDirectoryListKey(dir), redis.Z{Score: 0, Member: name}).Err(); err != nil {
return fmt.Errorf("persisting %s in parent dir: %v", entry.FullPath, err)
}
}