forked from mirror/redis
solve possible unit test errors in ring_test.go
/redis/ring_test.go:560, Expected: <int>: 10, to equal: <int>: 9 /redis/ring_test.go:560, Expected: <int>: 1, to equal: <int>: 0 Signed-off-by: monkey <golang@88.com>
This commit is contained in:
parent
e5cde8f9a7
commit
f4ae0ba02b
10
ring_test.go
10
ring_test.go
|
@ -533,6 +533,16 @@ var _ = Describe("Ring watch", func() {
|
||||||
})
|
})
|
||||||
|
|
||||||
It("respects max size on multi", func() {
|
It("respects max size on multi", func() {
|
||||||
|
//this test checks the number of "pool.conn"
|
||||||
|
//if the health check is performed at the same time
|
||||||
|
//conn will be used, resulting in an abnormal number of "pool.conn".
|
||||||
|
//
|
||||||
|
//redis.NewRing() does not have an option to prohibit health checks.
|
||||||
|
//set a relatively large time here to avoid health checks.
|
||||||
|
opt := redisRingOptions()
|
||||||
|
opt.HeartbeatFrequency = 72 * time.Hour
|
||||||
|
ring = redis.NewRing(opt)
|
||||||
|
|
||||||
perform(1000, func(id int) {
|
perform(1000, func(id int) {
|
||||||
var ping *redis.StatusCmd
|
var ping *redis.StatusCmd
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue