redis/go-redis
1
0
Fork 0
mirror of https://github.com/redis/go-redis.git synced 2025-06-12 14:21:52 +03:00
Code Activity

Use a lock-free connection pool

Browse Source
This commit is contained in:
Dimitrij Denissenko
2015-01-31 13:20:37 +00:00
parent c3ab344f84
commit 9f9822edd2
6 changed files with 118 additions and 110 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
commands_test.go
View File

@ -17,7 +17,8 @@ var _ = Describe("Commands", func() {
BeforeEach(func() {
client = redis.NewTCPClient(&redis.Options{
Addr: redisAddr,
Addr: redisAddr,
PoolTimeout: 30 * time.Second,
})
})
@ -1116,6 +1117,8 @@ var _ = Describe("Commands", func() {
started := make(chan bool)
done := make(chan bool)
go func() {
defer GinkgoRecover()
started <- true
bLPop := client.BLPop(0, "list")
Expect(bLPop.Err()).NotTo(HaveOccurred())
@ -1161,6 +1164,8 @@ var _ = Describe("Commands", func() {
started := make(chan bool)
done := make(chan bool)
go func() {
defer GinkgoRecover()
started <- true
brpop := client.BRPop(0, "list")
Expect(brpop.Err()).NotTo(HaveOccurred())
@ -2190,7 +2195,9 @@ var _ = Describe("Commands", func() {
wg.Add(1)
go func() {
defer GinkgoRecover()
defer wg.Done()
for {
cmds, err := safeIncr()
if err == redis.TxFailedErr {