re
/
redis
forked from mirror/redis
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Handle test failures

This commit is contained in:
Dimitrij Denissenko 2015-04-17 14:03:34 +01:00
parent e91b88fa17
commit 60e0221c3d
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
pipeline_test.go
View File

@ -123,6 +123,9 @@ var _ = Describe("Pipelining", func() {
wg.Add(N) wg.Add(N)
for i := 0; i < N; i++ { for i := 0; i < N; i++ {
go func(i int) { go func(i int) {
defer GinkgoRecover()
defer wg.Done()
pipeline := client.Pipeline() pipeline := client.Pipeline()
msg1 := "echo" + strconv.Itoa(i) msg1 := "echo" + strconv.Itoa(i)
@ -142,8 +145,6 @@ var _ = Describe("Pipelining", func() {
Expect(echo2.Val()).To(Equal(msg2)) Expect(echo2.Val()).To(Equal(msg2))
Expect(pipeline.Close()).NotTo(HaveOccurred()) Expect(pipeline.Close()).NotTo(HaveOccurred())
wg.Done()
}(i) }(i)
} }
wg.Wait() wg.Wait()