Skip to content

Commit

Permalink
redis-port, rename zset.Value to zset.Member
Browse files Browse the repository at this point in the history
  • Loading branch information
spinlock committed Nov 12, 2014
1 parent 94eec37 commit dbe01b8
Show file tree
Hide file tree
Showing 4 changed files with 8 additions and 8 deletions.
2 changes: 1 addition & 1 deletion ext/redis-port/cmd/decode.go
Original file line number Diff line number Diff line change
Expand Up @@ -108,7 +108,7 @@ func Decode(ncpu int, input, output string) {
}
case rdb.ZSet:
for _, x := range obj {
mem := toHexString(x.Value)
mem := toHexString(x.Member)
fmt.Fprintf(&b, "db=%d type=%s expireat=%d key=%s member=%s score=%f\n", e.DB, "zset", e.ExpireAt, key, mem, x.Score)
}
}
Expand Down
8 changes: 4 additions & 4 deletions ext/redis-port/rdb/decode.go
Original file line number Diff line number Diff line change
Expand Up @@ -106,8 +106,8 @@ func (d *decoder) Zadd(key []byte, score float64, member []byte) {
d.err = fmt.Errorf("invalid object, not a zset")
case ZSet:
v := struct {
Value []byte
Score float64
Member []byte
Score float64
}{
member,
score,
Expand All @@ -123,6 +123,6 @@ type HashMap []struct {
}
type Set [][]byte
type ZSet []struct {
Value []byte
Score float64
Member []byte
Score float64
}
2 changes: 1 addition & 1 deletion ext/redis-port/rdb/decode_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -204,7 +204,7 @@ func TestDecodeZSet(t *testing.T) {
}
zset := make(map[string]float64)
for _, ent := range val {
zset[string(ent.Value)] = ent.Score
zset[string(ent.Member)] = ent.Score
}
if len(zset) != 32 || len(zset) != len(val) {
t.Fatalf("len(zset) = %d/%d, expect = 32", len(zset), len(val))
Expand Down
4 changes: 2 additions & 2 deletions ext/redis-port/rdb/loader_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -374,7 +374,7 @@ func TestLoadZSetAndZSetZiplist(t *testing.T) {
val1 := obj1.(ZSet)
zset1 := make(map[string]float64)
for _, ent := range val1 {
zset1[string(ent.Value)] = ent.Score
zset1[string(ent.Member)] = ent.Score
}
if len(zset1) != 16 || len(zset1) != len(val1) {
t.Fatalf("len(zset1) = %d/%d, expect = 16", len(zset1), len(val1))
Expand All @@ -390,7 +390,7 @@ func TestLoadZSetAndZSetZiplist(t *testing.T) {
val2 := obj2.(ZSet)
zset2 := make(map[string]float64)
for _, ent := range val2 {
zset2[string(ent.Value)] = ent.Score
zset2[string(ent.Member)] = ent.Score
}
if len(zset2) != 32 || len(zset2) != len(val2) {
t.Fatalf("len(zset2) = %d/%d, expect = 32", len(zset2), len(val2))
Expand Down

0 comments on commit dbe01b8

Please sign in to comment.