[GitHub] [pulsar-client-go] wolfstudy opened a new issue #47: fatal error: concurrent map read and map write

[GitBox <gi...@apache.org>]

wolfstudy opened a new issue #47: fatal error: concurrent map read and map write
URL: https://github.com/apache/pulsar-client-go/issues/47
 
 
   #### Expected behavior
   
   In `connection` struct, the map of `pendingReqs` is concurrent safe.
   
   ```
   pendingReqs      map[uint64]*request
   ```
   
   #### Actual behavior
   
   ```
   atal error: concurrent map read and map write
   
   goroutine 27 [running]:
   runtime.throw(0x450438e, 0x21)
   	/usr/local/Cellar/go/1.12.5/libexec/src/runtime/panic.go:617 +0x72 fp=0xc0000d3ca0 sp=0xc0000d3c70 pc=0x402fc42
   runtime.mapaccess2_fast64(0x4475040, 0xc0000a0210, 0x7, 0x404f168, 0x3a2c156a93503)
   	/usr/local/Cellar/go/1.12.5/libexec/src/runtime/map_fast64.go:61 +0x1c2 fp=0xc0000d3cc8 sp=0xc0000d3ca0 pc=0x40139c2
   github.com/apache/pulsar-client-go/pulsar/internal.(*connection).handleResponse(0xc000166000, 0x7, 0xc0004d6160)
   	/Users/wolf4j/github.com/apache/pulsar-client-go/pulsar/internal/connection.go:377 +0x4f fp=0xc0000d3d40 sp=0xc0000d3cc8 pc=0x430d19f
   github.com/apache/pulsar-client-go/pulsar/internal.(*connection).receivedCommand(0xc000166000, 0xc0004d6160, 0x0, 0x0, 0x0)
   	/Users/wolf4j/github.com/apache/pulsar-client-go/pulsar/internal/connection.go:319 +0x266 fp=0xc0000d3db0 sp=0xc0000d3d40 pc=0x430cf06
   github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readFromConnection(0xc000138100)
   	/Users/wolf4j/github.com/apache/pulsar-client-go/pulsar/internal/connection_reader.go:54 +0x17d fp=0xc0000d3fd8 sp=0xc0000d3db0 pc=0x430efdd
   runtime.goexit()
   	/usr/local/Cellar/go/1.12.5/libexec/src/runtime/asm_amd64.s:1337 +0x1 fp=0xc0000d3fe0 sp=0xc0000d3fd8 pc=0x405e381
   created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run
   	/Users/wolf4j/github.com/apache/pulsar-client-go/pulsar/internal/connection.go:250 +0x58
   
   goroutine 1 [chan receive]:
   testing.(*T).Run(0xc00012e100, 0x45042a7, 0x21, 0x4513230, 0x407cb01)
   	/usr/local/Cellar/go/1.12.5/libexec/src/testing/testing.go:917 +0x381
   testing.runTests.func1(0xc00012e000)
   	/usr/local/Cellar/go/1.12.5/libexec/src/testing/testing.go:1157 +0x78
   testing.tRunner(0xc00012e000, 0xc0000d7e30)
   	/usr/local/Cellar/go/1.12.5/libexec/src/testing/testing.go:865 +0xc0
   testing.runTests(0xc00000e4c0, 0x48a2a00, 0x20, 0x20, 0x0)
   	/usr/local/Cellar/go/1.12.5/libexec/src/testing/testing.go:1155 +0x2a9
   testing.(*M).Run(0xc000126000, 0x0)
   	/usr/local/Cellar/go/1.12.5/libexec/src/testing/testing.go:1072 +0x162
   main.main()
   	_testmain.go:104 +0x13e
   ```
   
   #### Steps to reproduce
   
   How can we reproduce the issue
   
   #### System configuration
   **Pulsar version**: x.y
   

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services