Skip to content

Instantly share code, notes, and snippets.

@meson10

meson10/gilmour_race_condition.go

Created August 18, 2016 04:27
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save meson10/ffa6ceb29f360f4b9d2608e081f65b01 to your computer and use it in GitHub Desktop.
Save meson10/ffa6ceb29f360f4b9d2608e081f65b01 to your computer and use it in GitHub Desktop.
Download ZIP
Gilmour race condition
Raw
gilmour_race_condition.go
piyush:gilmour-e-go master λ go test --race -v ./...
=== RUN TestMergeHash
--- PASS: TestMergeHash (0.00s)
=== RUN TestMergeMismatch
--- PASS: TestMergeMismatch (0.00s)
=== RUN TestMergePointer
--- PASS: TestMergePointer (0.00s)
=== RUN TestMergeInterface
--- PASS: TestMergeInterface (0.00s)
=== RUN TestMergeInterfacePointer
--- PASS: TestMergeInterfacePointer (0.00s)
=== RUN TestFuncComposition
--- PASS: TestFuncComposition (0.00s)
=== RUN TestCompositionExecute
==================
WARNING: DATA RACE
Write at 0x00c420076458 by goroutine 17:
gopkg.in/mohandutt134/redis.v4/internal/pool.(*Conn).Write()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/internal/pool/conn.go:52 +0x8b
gopkg.in/mohandutt134/redis%2ev4.writeCmd()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/command.go:67 +0x28c
gopkg.in/mohandutt134/redis%2ev4.(*PubSub).subscribe()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/pubsub.go:67 +0x31a
gopkg.in/mohandutt134/redis%2ev4.(*PubSub).Subscribe()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/pubsub.go:72 +0x8c
gopkg.in/gilmour-libs/gilmour-e-go.v4/backends.(*Redis).Subscribe()
/Users/piyush/meson10/GOPATH/src/gopkg.in/gilmour-libs/gilmour-e-go.v4/backends/redis.go:144 +0x22c
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).subscribe()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:279 +0xf5
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).ReplyTo()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:373 +0x174
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).request()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:407 +0x2eb
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*RequestComposer).Execute()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/request.go:80 +0xd2
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.TestCompositionExecute()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_test.go:87 +0x2ad
testing.tRunner()
/usr/local/Cellar/go/1.7/libexec/src/testing/testing.go:610 +0xc9
Previous write at 0x00c420076458 by goroutine 9:
gopkg.in/mohandutt134/redis.v4/internal/pool.(*Conn).Read()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/internal/pool/conn.go:42 +0x8b
bufio.(*Reader).fill()
/usr/local/Cellar/go/1.7/libexec/src/bufio/bufio.go:97 +0x196
bufio.(*Reader).ReadSlice()
/usr/local/Cellar/go/1.7/libexec/src/bufio/bufio.go:330 +0x1b4
bufio.(*Reader).ReadLine()
/usr/local/Cellar/go/1.7/libexec/src/bufio/bufio.go:359 +0x55
gopkg.in/mohandutt134/redis%2ev4.readLine()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:227 +0x58
gopkg.in/mohandutt134/redis%2ev4.readArrayReply()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:369 +0x50
gopkg.in/mohandutt134/redis%2ev4.(*SliceCmd).readReply()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/command.go:214 +0x48
gopkg.in/mohandutt134/redis%2ev4.(*PubSub).ReceiveTimeout()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/pubsub.go:223 +0x136
gopkg.in/mohandutt134/redis%2ev4.(*PubSub).Receive()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/pubsub.go:236 +0x45
gopkg.in/gilmour-libs/gilmour-e-go.v4/backends.(*Redis).setupListeners.func1()
/Users/piyush/meson10/GOPATH/src/gopkg.in/gilmour-libs/gilmour-e-go.v4/backends/redis.go:210 +0x96
Goroutine 17 (running) created at:
testing.(*T).Run()
/usr/local/Cellar/go/1.7/libexec/src/testing/testing.go:646 +0x52f
testing.RunTests.func1()
/usr/local/Cellar/go/1.7/libexec/src/testing/testing.go:793 +0xb9
testing.tRunner()
/usr/local/Cellar/go/1.7/libexec/src/testing/testing.go:610 +0xc9
testing.RunTests()
/usr/local/Cellar/go/1.7/libexec/src/testing/testing.go:799 +0x4ba
testing.(*M).Run()
/usr/local/Cellar/go/1.7/libexec/src/testing/testing.go:743 +0x12f
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.TestMain()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour_test.go:665 +0x316
main.main()
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go/_test/_testmain.go:154 +0x1b5
Goroutine 9 (running) created at:
gopkg.in/gilmour-libs/gilmour-e-go.v4/backends.(*Redis).setupListeners()
/Users/piyush/meson10/GOPATH/src/gopkg.in/gilmour-libs/gilmour-e-go.v4/backends/redis.go:228 +0x56
gopkg.in/gilmour-libs/gilmour-e-go.v4/backends.(*Redis).Start()
/Users/piyush/meson10/GOPATH/src/gopkg.in/gilmour-libs/gilmour-e-go.v4/backends/redis.go:201 +0x42
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).Start()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:42 +0x84
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.TestMain()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour_test.go:663 +0x305
main.main()
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go/_test/_testmain.go:154 +0x1b5
==================
Unsubscribing one shot response topic gilmour.response.72720f66-152a-42d3-ac19-dbcfe55c6f16
--- PASS: TestCompositionExecute (0.00s)
=== RUN TestCompositionMergeExecute
Unsubscribing one shot response topic gilmour.response.bf676ba7-ae40-4482-9bcb-e22d4d52fd7b
--- PASS: TestCompositionMergeExecute (0.00s)
=== RUN TestComposePipe
Unsubscribing one shot response topic gilmour.response.70f20b50-f53d-47f1-bd00-19670d66e919
--- PASS: TestComposePipe (0.00s)
=== RUN TestComposeComplex
Unsubscribing one shot response topic gilmour.response.ac555e3b-72df-480d-b102-cd8460c60503
==================
WARNING: DATA RACE
Read at 0x00c4200761d0 by goroutine 9:
gopkg.in/mohandutt134/redis%2ev4.(*PubSub).ReceiveTimeout()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/pubsub.go:212 +0x54
gopkg.in/mohandutt134/redis%2ev4.(*PubSub).Receive()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/pubsub.go:236 +0x45
gopkg.in/gilmour-libs/gilmour-e-go.v4/backends.(*Redis).setupListeners.func1()
/Users/piyush/meson10/GOPATH/src/gopkg.in/gilmour-libs/gilmour-e-go.v4/backends/redis.go:210 +0x96
Previous write at 0x00c4200761d0 by goroutine 43:
gopkg.in/mohandutt134/redis%2ev4.(*PubSub).Subscribe()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/pubsub.go:75 +0x206
gopkg.in/gilmour-libs/gilmour-e-go.v4/backends.(*Redis).Subscribe()
/Users/piyush/meson10/GOPATH/src/gopkg.in/gilmour-libs/gilmour-e-go.v4/backends/redis.go:144 +0x22c
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).subscribe()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:279 +0xf5
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).ReplyTo()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:373 +0x174
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).request()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:407 +0x2eb
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*RequestComposer).Execute()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/request.go:80 +0xd2
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.performJob()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition.go:51 +0x5a
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*PipeComposition).Execute.func1()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_pipe.go:10 +0x83
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*PipeComposition).Execute.func1()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_pipe.go:14 +0x205
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*PipeComposition).Execute()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_pipe.go:19 +0x18d
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.TestComposeComplex()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_test.go:151 +0x5d4
testing.tRunner()
/usr/local/Cellar/go/1.7/libexec/src/testing/testing.go:610 +0xc9
Goroutine 9 (running) created at:
gopkg.in/gilmour-libs/gilmour-e-go.v4/backends.(*Redis).setupListeners()
/Users/piyush/meson10/GOPATH/src/gopkg.in/gilmour-libs/gilmour-e-go.v4/backends/redis.go:228 +0x56
gopkg.in/gilmour-libs/gilmour-e-go.v4/backends.(*Redis).Start()
/Users/piyush/meson10/GOPATH/src/gopkg.in/gilmour-libs/gilmour-e-go.v4/backends/redis.go:201 +0x42
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).Start()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:42 +0x84
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.TestMain()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour_test.go:663 +0x305
main.main()
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go/_test/_testmain.go:154 +0x1b5
Goroutine 43 (running) created at:
testing.(*T).Run()
/usr/local/Cellar/go/1.7/libexec/src/testing/testing.go:646 +0x52f
testing.RunTests.func1()
/usr/local/Cellar/go/1.7/libexec/src/testing/testing.go:793 +0xb9
testing.tRunner()
/usr/local/Cellar/go/1.7/libexec/src/testing/testing.go:610 +0xc9
testing.RunTests()
/usr/local/Cellar/go/1.7/libexec/src/testing/testing.go:799 +0x4ba
testing.(*M).Run()
/usr/local/Cellar/go/1.7/libexec/src/testing/testing.go:743 +0x12f
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.TestMain()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour_test.go:665 +0x316
main.main()
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go/_test/_testmain.go:154 +0x1b5
==================
Unsubscribing one shot response topic gilmour.response.f12e1dc9-067d-4125-8870-cc6799966223
--- PASS: TestComposeComplex (0.01s)
=== RUN TestComposeNested
Unsubscribing one shot response topic gilmour.response.89f16acb-9f97-42f1-9784-fddb3001f4d5
Unsubscribing one shot response topic gilmour.response.557fd665-65bd-40bf-89c8-115214506ba3
--- PASS: TestComposeNested (0.01s)
=== RUN TestComposeAndAnd
Unsubscribing one shot response topic gilmour.response.05a4e9ce-5997-4e23-b9a4-727ac8b14138
Unsubscribing one shot response topic gilmour.response.2e1df679-1bf5-43cb-9676-d683368d0cf3
--- PASS: TestComposeAndAnd (0.01s)
=== RUN TestComposeAndAndFail
Unsubscribing one shot response topic gilmour.response.7eb2c09d-fcc8-44f6-a878-3cd6cb393f0d
Reporting Error. Code 500 Sender gilmour.response.13c2a5ad-2779-4558-912d-15ae5a5a3cf5 Topic {"data":"goroutine 117 [running]:\n_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).handleRequest.func1.1(0xc4200c0540, 0xc42016a000)\n\t/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:133 +0x9e\npanic(0x25aee0, 0xc4200d0580)\n\t/usr/local/Cellar/go/1.7/libexec/src/runtime/panic.go:458 +0x271\n_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.setup.func1(0xc4200ce640, 0xc4200c0540)\n\t/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_test.go:18 +0x7b\n_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).ReplyTo.func1(0xc4200ce640, 0xc4200c0540)\n\t/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:370 +0x51\n_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).handleRequest.func1(0xc4200c0540, 0xc420094b70, 0xc4200ce640, 0xc42016a000)\n\t/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:141 +0x90\ncreated by _/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).handleRequest\n\t/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:143 +0x1f4\n","code":500,"sender":"gilmour.response.13c2a5ad-2779-4558-912d-15ae5a5a3cf5"}
Unsubscribing one shot response topic gilmour.response.13c2a5ad-2779-4558-912d-15ae5a5a3cf5
--- PASS: TestComposeAndAndFail (0.01s)
=== RUN TestComposeBatchPass
Unsubscribing one shot response topic gilmour.response.31d9c09c-7043-42f0-aad0-bf76f0b15d06
Unsubscribing one shot response topic gilmour.response.e0d079f4-1eff-49e7-9fcd-28e4f0cae703
--- PASS: TestComposeBatchPass (0.01s)
=== RUN TestComposeBatchWontFail
Unsubscribing one shot response topic gilmour.response.504edafb-0ece-4d55-8b0e-a6b9a8ba8f27
Reporting Error. Code 500 Sender gilmour.response.38605ebe-421b-44bd-83cb-543a0277c2ed Topic {"data":"goroutine 133 [running]:\n_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).handleRequest.func1.1(0xc4200e9640, 0xc4200fe4d0)\n\t/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:133 +0x9e\npanic(0x25aee0, 0xc4200f1300)\n\t/usr/local/Cellar/go/1.7/libexec/src/runtime/panic.go:458 +0x271\n_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.setup.func1(0xc4200e3440, 0xc4200e9640)\n\t/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_test.go:18 +0x7b\n_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).ReplyTo.func1(0xc4200e3440, 0xc4200e9640)\n\t/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:370 +0x51\n_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).handleRequest.func1(0xc4200e9640, 0xc420094b70, 0xc4200e3440, 0xc4200fe4d0)\n\t/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:141 +0x90\ncreated by _/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).handleRequest\n\t/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:143 +0x1f4\n","code":500,"sender":"gilmour.response.38605ebe-421b-44bd-83cb-543a0277c2ed"}
Unsubscribing one shot response topic gilmour.response.38605ebe-421b-44bd-83cb-543a0277c2ed
Unsubscribing one shot response topic gilmour.response.0445ff2d-5cd7-41b7-8468-b4cc3377f704
--- PASS: TestComposeBatchWontFail (0.01s)
=== RUN TestBatch
Unsubscribing one shot response topic gilmour.response.650e4195-302d-4fe2-a27c-8df24263ad69
Unsubscribing one shot response topic gilmour.response.6b9e03a5-8b52-4c61-a2c3-1798fcc7c757
Unsubscribing one shot response topic gilmour.response.d04696d5-59fa-4edc-a9ec-eac5ef0e1f0b
--- PASS: TestBatch (0.01s)
=== RUN TestBatchRecordOutput
Unsubscribing one shot response topic gilmour.response.9e1bae62-ccb6-45f4-a378-cc62bd7ed0f1
Unsubscribing one shot response topic gilmour.response.53aa1b3e-39e1-4639-ae86-fce01c1ab6da
Unsubscribing one shot response topic gilmour.response.8ded8efc-e811-4af4-a61a-ddccc4415390
--- PASS: TestBatchRecordOutput (0.01s)
=== RUN TestBatchBadRecord
Unsubscribing one shot response topic gilmour.response.e7391965-9a40-4f10-aa72-6076d3911bbe
Reporting Error. Code 500 Sender gilmour.response.94a93362-c847-4559-b435-aad1d835f95a Topic {"data":"goroutine 224 [running]:\n_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).handleRequest.func1.1(0xc4201c4000, 0xc42016a700)\n\t/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:133 +0x9e\npanic(0x25aee0, 0xc4200d1d00)\n\t/usr/local/Cellar/go/1.7/libexec/src/runtime/panic.go:458 +0x271\n_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.setup.func1(0xc4200cfe20, 0xc4201c4000)\n\t/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_test.go:18 +0x7b\n_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).ReplyTo.func1(0xc4200cfe20, 0xc4201c4000)\n\t/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:370 +0x51\n_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).handleRequest.func1(0xc4201c4000, 0xc420094b70, 0xc4200cfe20, 0xc42016a700)\n\t/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:141 +0x90\ncreated by _/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).handleRequest\n\t/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:143 +0x1f4\n","code":500,"sender":"gilmour.response.94a93362-c847-4559-b435-aad1d835f95a"}
Unsubscribing one shot response topic gilmour.response.94a93362-c847-4559-b435-aad1d835f95a
Unsubscribing one shot response topic gilmour.response.454bb18f-f6f9-4b0e-90a1-87370a569e60
--- PASS: TestBatchBadRecord (0.01s)
=== RUN TestOrOr
Reporting Error. Code 500 Sender gilmour.response.a2d59328-e364-4a9e-a2df-0274ef6d638c Topic {"data":"goroutine 242 [running]:\n_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).handleRequest.func1.1(0xc4201c4240, 0xc42016a7e0)\n\t/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:133 +0x9e\npanic(0x25aee0, 0xc4200d1e50)\n\t/usr/local/Cellar/go/1.7/libexec/src/runtime/panic.go:458 +0x271\n_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.setup.func1(0xc4200cff20, 0xc4201c4240)\n\t/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_test.go:18 +0x7b\n_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).ReplyTo.func1(0xc4200cff20, 0xc4201c4240)\n\t/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:370 +0x51\n_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).handleRequest.func1(0xc4201c4240, 0xc420094b70, 0xc4200cff20, 0xc42016a7e0)\n\t/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:141 +0x90\ncreated by _/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).handleRequest\n\t/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:143 +0x1f4\n","code":500,"sender":"gilmour.response.a2d59328-e364-4a9e-a2df-0274ef6d638c"}
Unsubscribing one shot response topic gilmour.response.a2d59328-e364-4a9e-a2df-0274ef6d638c
Unsubscribing one shot response topic gilmour.response.80d6fda8-f941-4e73-a245-da0d90cc318d
--- PASS: TestOrOr (0.01s)
=== RUN TestParallel
==================
WARNING: DATA RACE
Write at 0x00c420076438 by goroutine 17:
gopkg.in/mohandutt134/redis%2ev4.writeCmd()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/command.go:58 +0x5f
gopkg.in/mohandutt134/redis%2ev4.(*PubSub).subscribe()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/pubsub.go:67 +0x31a
gopkg.in/mohandutt134/redis%2ev4.(*PubSub).Subscribe()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/pubsub.go:72 +0x8c
gopkg.in/gilmour-libs/gilmour-e-go.v4/backends.(*Redis).Subscribe()
/Users/piyush/meson10/GOPATH/src/gopkg.in/gilmour-libs/gilmour-e-go.v4/backends/redis.go:144 +0x22c
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).subscribe()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:279 +0xf5
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).ReplyTo()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:373 +0x174
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).request()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:407 +0x2eb
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*RequestComposer).Execute()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/request.go:80 +0xd2
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.performJob()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition.go:51 +0x5a
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*ParallelComposition).Execute.func1.1()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_parallel.go:30 +0x76
Previous write at 0x00c420076438 by goroutine 9:
gopkg.in/mohandutt134/redis.v4/internal/pool.(*Conn).ReadN()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/internal/pool/conn.go:70 +0x3c0
gopkg.in/mohandutt134/redis%2ev4.parseBytesReply()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:292 +0x21e
gopkg.in/mohandutt134/redis%2ev4.readReply()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:397 +0x2f4
gopkg.in/mohandutt134/redis%2ev4.sliceParser()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:443 +0xde
gopkg.in/mohandutt134/redis%2ev4.parseArrayReply()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:350 +0xdd
gopkg.in/mohandutt134/redis%2ev4.readArrayReply()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:377 +0x2cf
gopkg.in/mohandutt134/redis%2ev4.(*SliceCmd).readReply()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/command.go:214 +0x48
gopkg.in/mohandutt134/redis%2ev4.(*PubSub).ReceiveTimeout()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/pubsub.go:223 +0x136
gopkg.in/mohandutt134/redis%2ev4.(*PubSub).Receive()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/pubsub.go:236 +0x45
gopkg.in/gilmour-libs/gilmour-e-go.v4/backends.(*Redis).setupListeners.func1()
/Users/piyush/meson10/GOPATH/src/gopkg.in/gilmour-libs/gilmour-e-go.v4/backends/redis.go:210 +0x96
Goroutine 17 (running) created at:
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*ParallelComposition).Execute.func1()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_parallel.go:33 +0xb8
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*ParallelComposition).Execute.func1()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_parallel.go:36 +0x101
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*ParallelComposition).Execute.func1()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_parallel.go:36 +0x101
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*ParallelComposition).Execute()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_parallel.go:40 +0x13b
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.TestParallel()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_test.go:450 +0x4d3
testing.tRunner()
/usr/local/Cellar/go/1.7/libexec/src/testing/testing.go:610 +0xc9
Goroutine 9 (running) created at:
gopkg.in/gilmour-libs/gilmour-e-go.v4/backends.(*Redis).setupListeners()
/Users/piyush/meson10/GOPATH/src/gopkg.in/gilmour-libs/gilmour-e-go.v4/backends/redis.go:228 +0x56
gopkg.in/gilmour-libs/gilmour-e-go.v4/backends.(*Redis).Start()
/Users/piyush/meson10/GOPATH/src/gopkg.in/gilmour-libs/gilmour-e-go.v4/backends/redis.go:201 +0x42
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).Start()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:42 +0x84
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.TestMain()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour_test.go:663 +0x305
main.main()
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go/_test/_testmain.go:154 +0x1b5
==================
==================
WARNING: DATA RACE
Write at 0x00c4200be000 by goroutine 17:
gopkg.in/mohandutt134/redis%2ev4.appendArgs()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:110 +0x8d
gopkg.in/mohandutt134/redis%2ev4.writeCmd()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/command.go:61 +0x14d
gopkg.in/mohandutt134/redis%2ev4.(*PubSub).subscribe()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/pubsub.go:67 +0x31a
gopkg.in/mohandutt134/redis%2ev4.(*PubSub).Subscribe()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/pubsub.go:72 +0x8c
gopkg.in/gilmour-libs/gilmour-e-go.v4/backends.(*Redis).Subscribe()
/Users/piyush/meson10/GOPATH/src/gopkg.in/gilmour-libs/gilmour-e-go.v4/backends/redis.go:144 +0x22c
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).subscribe()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:279 +0xf5
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).ReplyTo()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:373 +0x174
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).request()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:407 +0x2eb
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*RequestComposer).Execute()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/request.go:80 +0xd2
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.performJob()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition.go:51 +0x5a
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*ParallelComposition).Execute.func1.1()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_parallel.go:30 +0x76
Previous write at 0x00c4200be000 by goroutine 9:
runtime.slicecopy()
/usr/local/Cellar/go/1.7/libexec/src/runtime/slice.go:144 +0x0
bufio.(*Reader).Read()
/usr/local/Cellar/go/1.7/libexec/src/bufio/bufio.go:216 +0x21a
io.ReadAtLeast()
/usr/local/Cellar/go/1.7/libexec/src/io/io.go:307 +0xb1
io.ReadFull()
/usr/local/Cellar/go/1.7/libexec/src/io/io.go:325 +0x72
gopkg.in/mohandutt134/redis.v4/internal/pool.(*Conn).ReadN()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/internal/pool/conn.go:72 +0x284
gopkg.in/mohandutt134/redis%2ev4.parseBytesReply()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:292 +0x21e
gopkg.in/mohandutt134/redis%2ev4.readReply()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:397 +0x2f4
gopkg.in/mohandutt134/redis%2ev4.sliceParser()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:443 +0xde
gopkg.in/mohandutt134/redis%2ev4.parseArrayReply()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:350 +0xdd
gopkg.in/mohandutt134/redis%2ev4.readArrayReply()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:377 +0x2cf
gopkg.in/mohandutt134/redis%2ev4.(*SliceCmd).readReply()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/command.go:214 +0x48
gopkg.in/mohandutt134/redis%2ev4.(*PubSub).ReceiveTimeout()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/pubsub.go:223 +0x136
gopkg.in/mohandutt134/redis%2ev4.(*PubSub).Receive()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/pubsub.go:236 +0x45
gopkg.in/gilmour-libs/gilmour-e-go.v4/backends.(*Redis).setupListeners.func1()
/Users/piyush/meson10/GOPATH/src/gopkg.in/gilmour-libs/gilmour-e-go.v4/backends/redis.go:210 +0x96
Goroutine 17 (running) created at:
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*ParallelComposition).Execute.func1()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_parallel.go:33 +0xb8
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*ParallelComposition).Execute.func1()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_parallel.go:36 +0x101
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*ParallelComposition).Execute.func1()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_parallel.go:36 +0x101
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*ParallelComposition).Execute()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_parallel.go:40 +0x13b
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.TestParallel()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_test.go:450 +0x4d3
testing.tRunner()
/usr/local/Cellar/go/1.7/libexec/src/testing/testing.go:610 +0xc9
Goroutine 9 (running) created at:
gopkg.in/gilmour-libs/gilmour-e-go.v4/backends.(*Redis).setupListeners()
/Users/piyush/meson10/GOPATH/src/gopkg.in/gilmour-libs/gilmour-e-go.v4/backends/redis.go:228 +0x56
gopkg.in/gilmour-libs/gilmour-e-go.v4/backends.(*Redis).Start()
/Users/piyush/meson10/GOPATH/src/gopkg.in/gilmour-libs/gilmour-e-go.v4/backends/redis.go:201 +0x42
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).Start()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:42 +0x84
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.TestMain()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour_test.go:663 +0x305
main.main()
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go/_test/_testmain.go:154 +0x1b5
==================
==================
WARNING: DATA RACE
Write at 0x00c4200be008 by goroutine 17:
runtime.slicestringcopy()
/usr/local/Cellar/go/1.7/libexec/src/runtime/slice.go:179 +0x0
gopkg.in/mohandutt134/redis%2ev4.appendString()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:41 +0x1a9
gopkg.in/mohandutt134/redis%2ev4.appendArg()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:60 +0xd85
gopkg.in/mohandutt134/redis%2ev4.appendArgs()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:115 +0x1f8
gopkg.in/mohandutt134/redis%2ev4.writeCmd()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/command.go:61 +0x14d
gopkg.in/mohandutt134/redis%2ev4.(*PubSub).subscribe()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/pubsub.go:67 +0x31a
gopkg.in/mohandutt134/redis%2ev4.(*PubSub).Subscribe()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/pubsub.go:72 +0x8c
gopkg.in/gilmour-libs/gilmour-e-go.v4/backends.(*Redis).Subscribe()
/Users/piyush/meson10/GOPATH/src/gopkg.in/gilmour-libs/gilmour-e-go.v4/backends/redis.go:144 +0x22c
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).subscribe()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:279 +0xf5
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).ReplyTo()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:373 +0x174
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).request()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:407 +0x2eb
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*RequestComposer).Execute()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/request.go:80 +0xd2
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.performJob()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition.go:51 +0x5a
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*ParallelComposition).Execute.func1.1()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_parallel.go:30 +0x76
Previous write at 0x00c4200be008 by goroutine 9:
runtime.slicecopy()
/usr/local/Cellar/go/1.7/libexec/src/runtime/slice.go:144 +0x0
bufio.(*Reader).Read()
/usr/local/Cellar/go/1.7/libexec/src/bufio/bufio.go:216 +0x21a
io.ReadAtLeast()
/usr/local/Cellar/go/1.7/libexec/src/io/io.go:307 +0xb1
io.ReadFull()
/usr/local/Cellar/go/1.7/libexec/src/io/io.go:325 +0x72
gopkg.in/mohandutt134/redis.v4/internal/pool.(*Conn).ReadN()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/internal/pool/conn.go:72 +0x284
gopkg.in/mohandutt134/redis%2ev4.parseBytesReply()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:292 +0x21e
gopkg.in/mohandutt134/redis%2ev4.readReply()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:397 +0x2f4
gopkg.in/mohandutt134/redis%2ev4.sliceParser()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:443 +0xde
gopkg.in/mohandutt134/redis%2ev4.parseArrayReply()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:350 +0xdd
gopkg.in/mohandutt134/redis%2ev4.readArrayReply()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:377 +0x2cf
gopkg.in/mohandutt134/redis%2ev4.(*SliceCmd).readReply()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/command.go:214 +0x48
gopkg.in/mohandutt134/redis%2ev4.(*PubSub).ReceiveTimeout()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/pubsub.go:223 +0x136
gopkg.in/mohandutt134/redis%2ev4.(*PubSub).Receive()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/pubsub.go:236 +0x45
gopkg.in/gilmour-libs/gilmour-e-go.v4/backends.(*Redis).setupListeners.func1()
/Users/piyush/meson10/GOPATH/src/gopkg.in/gilmour-libs/gilmour-e-go.v4/backends/redis.go:210 +0x96
Goroutine 17 (running) created at:
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*ParallelComposition).Execute.func1()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_parallel.go:33 +0xb8
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*ParallelComposition).Execute.func1()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_parallel.go:36 +0x101
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*ParallelComposition).Execute.func1()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_parallel.go:36 +0x101
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*ParallelComposition).Execute()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_parallel.go:40 +0x13b
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.TestParallel()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_test.go:450 +0x4d3
testing.tRunner()
/usr/local/Cellar/go/1.7/libexec/src/testing/testing.go:610 +0xc9
Goroutine 9 (running) created at:
gopkg.in/gilmour-libs/gilmour-e-go.v4/backends.(*Redis).setupListeners()
/Users/piyush/meson10/GOPATH/src/gopkg.in/gilmour-libs/gilmour-e-go.v4/backends/redis.go:228 +0x56
gopkg.in/gilmour-libs/gilmour-e-go.v4/backends.(*Redis).Start()
/Users/piyush/meson10/GOPATH/src/gopkg.in/gilmour-libs/gilmour-e-go.v4/backends/redis.go:201 +0x42
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).Start()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:42 +0x84
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.TestMain()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour_test.go:663 +0x305
main.main()
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go/_test/_testmain.go:154 +0x1b5
==================
==================
WARNING: DATA RACE
Write at 0x00c4200be030 by goroutine 17:
runtime.slicestringcopy()
/usr/local/Cellar/go/1.7/libexec/src/runtime/slice.go:179 +0x0
gopkg.in/mohandutt134/redis%2ev4.appendString()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:41 +0x1a9
gopkg.in/mohandutt134/redis%2ev4.appendArg()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:60 +0xd85
gopkg.in/mohandutt134/redis%2ev4.appendArgs()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:115 +0x1f8
gopkg.in/mohandutt134/redis%2ev4.writeCmd()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/command.go:61 +0x14d
gopkg.in/mohandutt134/redis%2ev4.(*PubSub).subscribe()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/pubsub.go:67 +0x31a
gopkg.in/mohandutt134/redis%2ev4.(*PubSub).Subscribe()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/pubsub.go:72 +0x8c
gopkg.in/gilmour-libs/gilmour-e-go.v4/backends.(*Redis).Subscribe()
/Users/piyush/meson10/GOPATH/src/gopkg.in/gilmour-libs/gilmour-e-go.v4/backends/redis.go:144 +0x22c
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).subscribe()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:279 +0xf5
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).ReplyTo()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:373 +0x174
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).request()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:407 +0x2eb
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*RequestComposer).Execute()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/request.go:80 +0xd2
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.performJob()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition.go:51 +0x5a
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*ParallelComposition).Execute.func1.1()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_parallel.go:30 +0x76
Previous read at 0x00c4200be033 by goroutine 9:
runtime.slicebytetostring()
/usr/local/Cellar/go/1.7/libexec/src/runtime/string.go:76 +0x0
gopkg.in/mohandutt134/redis%2ev4.sliceParser()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:451 +0x416
gopkg.in/mohandutt134/redis%2ev4.parseArrayReply()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:350 +0xdd
gopkg.in/mohandutt134/redis%2ev4.readArrayReply()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:377 +0x2cf
gopkg.in/mohandutt134/redis%2ev4.(*SliceCmd).readReply()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/command.go:214 +0x48
gopkg.in/mohandutt134/redis%2ev4.(*PubSub).ReceiveTimeout()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/pubsub.go:223 +0x136
gopkg.in/mohandutt134/redis%2ev4.(*PubSub).Receive()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/pubsub.go:236 +0x45
gopkg.in/gilmour-libs/gilmour-e-go.v4/backends.(*Redis).setupListeners.func1()
/Users/piyush/meson10/GOPATH/src/gopkg.in/gilmour-libs/gilmour-e-go.v4/backends/redis.go:210 +0x96
Goroutine 17 (running) created at:
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*ParallelComposition).Execute.func1()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_parallel.go:33 +0xb8
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*ParallelComposition).Execute.func1()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_parallel.go:36 +0x101
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*ParallelComposition).Execute.func1()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_parallel.go:36 +0x101
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*ParallelComposition).Execute()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_parallel.go:40 +0x13b
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.TestParallel()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_test.go:450 +0x4d3
testing.tRunner()
/usr/local/Cellar/go/1.7/libexec/src/testing/testing.go:610 +0xc9
Goroutine 9 (running) created at:
gopkg.in/gilmour-libs/gilmour-e-go.v4/backends.(*Redis).setupListeners()
/Users/piyush/meson10/GOPATH/src/gopkg.in/gilmour-libs/gilmour-e-go.v4/backends/redis.go:228 +0x56
gopkg.in/gilmour-libs/gilmour-e-go.v4/backends.(*Redis).Start()
/Users/piyush/meson10/GOPATH/src/gopkg.in/gilmour-libs/gilmour-e-go.v4/backends/redis.go:201 +0x42
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).Start()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:42 +0x84
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.TestMain()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour_test.go:663 +0x305
main.main()
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go/_test/_testmain.go:154 +0x1b5
==================
Unsubscribing one shot response topic gilmour.response.62ba948c-1fd1-4ec0-90f7-dbc7aa45455b
Unsubscribing one shot response topic gilmour.response.cb3a68ef-f5c6-4910-8ff9-ee61cbd66445
Unsubscribing one shot response topic gilmour.response.75b56008-0d20-42a2-b532-93754bb7b269
--- PASS: TestParallel (0.02s)
=== RUN TestOrOrParallel
Reporting Error. Code 500 Sender gilmour.response.e714c5d7-c29c-48d7-9d2d-4ee77fd4049c Topic {"data":"goroutine 265 [running]:\n_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).handleRequest.func1.1(0xc4201ea1c0, 0xc4200591f0)\n\t/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:133 +0x9e\npanic(0x25aee0, 0xc42018df70)\n\t/usr/local/Cellar/go/1.7/libexec/src/runtime/panic.go:458 +0x271\n_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.setup.func1(0xc4201955c0, 0xc4201ea1c0)\n\t/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_test.go:18 +0x7b\n_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).ReplyTo.func1(0xc4201955c0, 0xc4201ea1c0)\n\t/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:370 +0x51\n_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).handleRequest.func1(0xc4201ea1c0, 0xc420094b70, 0xc4201955c0, 0xc4200591f0)\n\t/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:141 +0x90\ncreated by _/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).handleRequest\n\t/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:143 +0x1f4\n","code":500,"sender":"gilmour.response.e714c5d7-c29c-48d7-9d2d-4ee77fd4049c"}
Unsubscribing one shot response topic gilmour.response.e714c5d7-c29c-48d7-9d2d-4ee77fd4049c
Unsubscribing one shot response topic gilmour.response.6645def9-0ead-46ae-835c-8f910116e501
Unsubscribing one shot response topic gilmour.response.5efcac2c-20e9-45b9-ba00-53a97787cb74
Unsubscribing one shot response topic gilmour.response.98f97a0d-d96f-4ef0-bf50-7727a3638735
--- PASS: TestOrOrParallel (0.01s)
=== RUN TestParallelParallel
Unsubscribing one shot response topic gilmour.response.5fd059ce-a0ca-4b0c-9482-db5cfca88986
Unsubscribing one shot response topic gilmour.response.3ed208d4-af6c-4990-827f-d3627e932cdf
==================
WARNING: DATA RACE
Write at 0x00c4200be050 by goroutine 9:
runtime.slicecopy()
/usr/local/Cellar/go/1.7/libexec/src/runtime/slice.go:144 +0x0
bufio.(*Reader).Read()
/usr/local/Cellar/go/1.7/libexec/src/bufio/bufio.go:216 +0x21a
io.ReadAtLeast()
/usr/local/Cellar/go/1.7/libexec/src/io/io.go:307 +0xb1
io.ReadFull()
/usr/local/Cellar/go/1.7/libexec/src/io/io.go:325 +0x72
gopkg.in/mohandutt134/redis.v4/internal/pool.(*Conn).ReadN()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/internal/pool/conn.go:72 +0x284
gopkg.in/mohandutt134/redis%2ev4.parseBytesReply()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:292 +0x21e
gopkg.in/mohandutt134/redis%2ev4.readReply()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:397 +0x2f4
gopkg.in/mohandutt134/redis%2ev4.sliceParser()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:443 +0xde
gopkg.in/mohandutt134/redis%2ev4.parseArrayReply()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:350 +0xdd
gopkg.in/mohandutt134/redis%2ev4.readArrayReply()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:377 +0x2cf
gopkg.in/mohandutt134/redis%2ev4.(*SliceCmd).readReply()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/command.go:214 +0x48
gopkg.in/mohandutt134/redis%2ev4.(*PubSub).ReceiveTimeout()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/pubsub.go:223 +0x136
gopkg.in/mohandutt134/redis%2ev4.(*PubSub).Receive()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/pubsub.go:236 +0x45
gopkg.in/gilmour-libs/gilmour-e-go.v4/backends.(*Redis).setupListeners.func1()
/Users/piyush/meson10/GOPATH/src/gopkg.in/gilmour-libs/gilmour-e-go.v4/backends/redis.go:210 +0x96
Previous write at 0x00c4200be051 by goroutine 79:
gopkg.in/mohandutt134/redis%2ev4.appendString()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:42 +0x20e
gopkg.in/mohandutt134/redis%2ev4.appendArg()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:60 +0xd85
gopkg.in/mohandutt134/redis%2ev4.appendArgs()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/parser.go:115 +0x1f8
gopkg.in/mohandutt134/redis%2ev4.writeCmd()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/command.go:61 +0x14d
gopkg.in/mohandutt134/redis%2ev4.(*PubSub).subscribe()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/pubsub.go:67 +0x31a
gopkg.in/mohandutt134/redis%2ev4.(*PubSub).Unsubscribe()
/Users/piyush/meson10/GOPATH/src/gopkg.in/mohandutt134/redis.v4/pubsub.go:108 +0x81
gopkg.in/gilmour-libs/gilmour-e-go.v4/backends.(*Redis).Unsubscribe()
/Users/piyush/meson10/GOPATH/src/gopkg.in/gilmour-libs/gilmour-e-go.v4/backends/redis.go:131 +0x22c
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).unsubscribe()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:291 +0xd1
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).UnsubscribeReply()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:378 +0x78
Goroutine 9 (running) created at:
gopkg.in/gilmour-libs/gilmour-e-go.v4/backends.(*Redis).setupListeners()
/Users/piyush/meson10/GOPATH/src/gopkg.in/gilmour-libs/gilmour-e-go.v4/backends/redis.go:228 +0x56
gopkg.in/gilmour-libs/gilmour-e-go.v4/backends.(*Redis).Start()
/Users/piyush/meson10/GOPATH/src/gopkg.in/gilmour-libs/gilmour-e-go.v4/backends/redis.go:201 +0x42
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).Start()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:42 +0x84
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.TestMain()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour_test.go:663 +0x305
main.main()
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go/_test/_testmain.go:154 +0x1b5
Goroutine 79 (finished) created at:
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Gilmour).processMessage()
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/gilmour.go:93 +0x62c
==================
Unsubscribing one shot response topic gilmour.response.2af4fe2a-916a-4699-be73-aa7afb6815bc
Unsubscribing one shot response topic gilmour.response.ee04d4be-31dd-44ec-9c3b-b622eb550958
Unsubscribing one shot response topic gilmour.response.eb5ee31b-1a65-4f64-8c2e-95ca7a14f6a5
Unsubscribing one shot response topic gilmour.response.98e88be0-1219-44db-8bd7-6ac9606b219a
--- PASS: TestParallelParallel (0.02s)
=== RUN TestAndAndParallel
Unsubscribing one shot response topic gilmour.response.37939718-6a73-46da-9e3f-9f6657de5741
Unsubscribing one shot response topic gilmour.response.13d8e081-d425-4b1a-9aa4-5c545203fec0
Unsubscribing one shot response topic gilmour.response.aca360a5-f853-49fd-9caf-4d7dd84012b0
Unsubscribing one shot response topic gilmour.response.7ecc29b7-2f4b-468a-a8fc-55015607c8a8
--- PASS: TestAndAndParallel (0.01s)
=== RUN TestPipeParallel
--- FAIL: TestPipeParallel (0.00s)
panic: runtime error: invalid memory address or nil pointer dereference [recovered]
panic: runtime error: invalid memory address or nil pointer dereference
[signal SIGSEGV: segmentation violation code=0x1 addr=0x0 pc=0x8d67d]
goroutine 365 [running]:
panic(0x26a4c0, 0xc4200120f0)
/usr/local/Cellar/go/1.7/libexec/src/runtime/panic.go:500 +0x1ae
testing.tRunner.func1(0xc4201fd980)
/usr/local/Cellar/go/1.7/libexec/src/testing/testing.go:579 +0x474
panic(0x26a4c0, 0xc4200120f0)
/usr/local/Cellar/go/1.7/libexec/src/runtime/panic.go:458 +0x271
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*Response).Code(0x0, 0x0)
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/response.go:28 +0x3d
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*PipeComposition).Execute.func1(0xc42020f0e0, 0xc4201f9b40)
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_pipe.go:12 +0x14e
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.(*PipeComposition).Execute(0xc4201facd0, 0xc4201f9b00, 0xc4201f9b00, 0xc4201d2eb0, 0xc42020d210)
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_pipe.go:19 +0x18e
_/Users/piyush/workspace/gilmour-libs/gilmour-e-go.TestPipeParallel(0xc4201fd980)
/Users/piyush/workspace/gilmour-libs/gilmour-e-go/composition_test.go:610 +0x64c
testing.tRunner(0xc4201fd980, 0x2c5208)
/usr/local/Cellar/go/1.7/libexec/src/testing/testing.go:610 +0xca
created by testing.(*T).Run
/usr/local/Cellar/go/1.7/libexec/src/testing/testing.go:646 +0x530
FAIL _/Users/piyush/workspace/gilmour-libs/gilmour-e-go 0.173s
? _/Users/piyush/workspace/gilmour-libs/gilmour-e-go/backends [no test files]
? _/Users/piyush/workspace/gilmour-libs/gilmour-e-go/examples/composeclient [no test files]
? _/Users/piyush/workspace/gilmour-libs/gilmour-e-go/examples/composerver [no test files]
? _/Users/piyush/workspace/gilmour-libs/gilmour-e-go/examples/echoclient [no test files]
? _/Users/piyush/workspace/gilmour-libs/gilmour-e-go/examples/echoserver [no test files]
? _/Users/piyush/workspace/gilmour-libs/gilmour-e-go/examples/fibonacci [no test files]
? _/Users/piyush/workspace/gilmour-libs/gilmour-e-go/examples/logclient [no test files]
? _/Users/piyush/workspace/gilmour-libs/gilmour-e-go/examples/weatherclient [no test files]
? _/Users/piyush/workspace/gilmour-libs/gilmour-e-go/examples/weatherman [no test files]
? _/Users/piyush/workspace/gilmour-libs/gilmour-e-go/protocol [no test files]
? _/Users/piyush/workspace/gilmour-libs/gilmour-e-go/ui [no test files]
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment