mirror
/
redis
mirror of https://github.com/go-redis/redis.git
1
0
Fork 1
Code Issues Packages Projects Releases Wiki Activity

the timeout of WAIT command is in milliseconds.

This commit is contained in:
Ichinose Shogo 2017-02-24 18:03:21 +09:00 committed by Vladimir Mihailenco
parent fe9d145e7c
commit b8fb4a1150
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
commands.go
View File

@ -273,7 +273,7 @@ func (c *cmdable) Ping() *StatusCmd {
func (c *cmdable) Wait(numSlaves int, timeout time.Duration) *IntCmd { func (c *cmdable) Wait(numSlaves int, timeout time.Duration) *IntCmd {
cmd := NewIntCmd("wait", numSlaves, int(timeout/time.Second)) cmd := NewIntCmd("wait", numSlaves, int(timeout/time.Millisecond))
c.process(cmd) c.process(cmd)
return cmd return cmd
} }

4
commands_test.go
View File

@ -52,9 +52,11 @@ var _ = Describe("Commands", func() {
It("should Wait", func() { It("should Wait", func() {
// assume testing on single redis instance // assume testing on single redis instance
wait := client.Wait(0, time.Minute) start := time.Now()
wait := client.Wait(1, time.Second)
Expect(wait.Err()).NotTo(HaveOccurred()) Expect(wait.Err()).NotTo(HaveOccurred())
Expect(wait.Val()).To(Equal(int64(0))) Expect(wait.Val()).To(Equal(int64(0)))
Expect(time.Now()).To(BeTemporally("~", start.Add(time.Second), 800*time.Millisecond))
}) })
It("should Select", func() { It("should Select", func() {