diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-04-12 03:11:19 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-04-12 03:11:19 -0700 |
| commit | 1c2e920fa2831d871ec55fed04818fddaaaacbd5 (patch) | |
| tree | 061264920d56c197b55cac93985662f2ad33773e /weed | |
| parent | b5a713be6843d8899cfae1021ac54a18b9315dd2 (diff) | |
| download | seaweedfs-1c2e920fa2831d871ec55fed04818fddaaaacbd5.tar.xz seaweedfs-1c2e920fa2831d871ec55fed04818fddaaaacbd5.zip | |
fix compilation error
Diffstat (limited to 'weed')
| -rw-r--r-- | weed/filer2/redis2/universal_redis_store.go | 7 |
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) } } |
